a Ofo-@s(ddlZddlmZGdddeZdS)N)WAIT_RESOURCE_NOT_FOUNDc@sheZdZdZddZgiifddZgiifddZgiifdd Zgiifd d Zgiifd d Z dS)#QueueAdminClientCompositeOperationsa This class provides a wrapper around :py:class:`~oci.queue.QueueAdminClient` and offers convenience methods for operations that would otherwise need to be chained together. For example, instead of performing an action on a resource (e.g. launching an instance, creating a load balancer) and then using a waiter to wait for the resource to enter a given state, you can call a single method in this class to accomplish the same functionality cKs ||_dS)z Creates a new QueueAdminClientCompositeOperations object :param QueueAdminClient client: The service client which will be wrapped by this object N)client)selfrkwargsr/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/oci/queue/queue_admin_client_composite_operations.py__init__sz,QueueAdminClientCompositeOperations.__init__c s|jj||fi|}|s|Sdd|D|jd}z4tj|j|j|fdfddi|}|} | WSty} ztjj|g| dWYd} ~ n d} ~ 00dS) aE Calls :py:func:`~oci.queue.QueueAdminClient.change_queue_compartment` and waits for the :py:class:`~oci.queue.models.WorkRequest` to enter the given state(s). :param str queue_id: (required) unique Queue identifier :param oci.queue.models.ChangeQueueCompartmentDetails change_queue_compartment_details: (required) The information to be updated. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.change_queue_compartment` :param dict waiter_kwargs: A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds`` as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait cSsg|] }|qSrlower.0wrrr 3zcQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_state..opc-work-request-idevaluate_responsecs t|jdot|jdvSNstatusgetattrdatar rlowered_wait_for_statesrr:rzaQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_state..partial_resultscauseN) rchange_queue_compartmentheadersoci wait_untilget_work_request Exception exceptionsCompositeOperationError) rqueue_id change_queue_compartment_detailswait_for_statesoperation_kwargs waiter_kwargsoperation_resultwait_for_resource_id waiter_resultresult_to_returnerrr+change_queue_compartment_and_wait_for_states$   zOQueueAdminClientCompositeOperations.change_queue_compartment_and_wait_for_statec s|jj|fi|}|s|Sdd|D|jd}z4tj|j|j|fdfddi|}|}|WSty} ztjj|g| dWYd} ~ n d} ~ 00dS) a Calls :py:func:`~oci.queue.QueueAdminClient.create_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest` to enter the given state(s). :param oci.queue.models.CreateQueueDetails create_queue_details: (required) Details for the new Queue. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.create_queue` :param dict waiter_kwargs: A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds`` as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait cSsg|] }|qSrr r rrrrYrzWQueueAdminClientCompositeOperations.create_queue_and_wait_for_state..rrcs t|jdot|jdvSrrrrrrr`rzUQueueAdminClientCompositeOperations.create_queue_and_wait_for_state..rN) r create_queuer!r"r#r$r%r&r') rcreate_queue_detailsr*r+r,r-r.r/r0r1rrrcreate_queue_and_wait_for_stateCs$   zCQueueAdminClientCompositeOperations.create_queue_and_wait_for_statec sd}z|jj|fi|}WnFtjjyb}z*|jdkrJtWYd}~S|WYd}~n d}~00|sl|Sdd|D|jd}z4tj|j|j |fdfddi|}|} | WSt y}ztjj |g|d WYd}~n d}~00dS) a Calls :py:func:`~oci.queue.QueueAdminClient.delete_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest` to enter the given state(s). :param str queue_id: (required) unique Queue identifier :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.delete_queue` :param dict waiter_kwargs: A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds`` as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait NicSsg|] }|qSrr r rrrrrzWQueueAdminClientCompositeOperations.delete_queue_and_wait_for_state..rrcs t|jdot|jdvSrrrrrrrrzUQueueAdminClientCompositeOperations.delete_queue_and_wait_for_state..r) r delete_queuer"r& ServiceErrorrrr!r#r$r%r') rr(r*r+r,r-r1r.r/r0rrrdelete_queue_and_wait_for_stateis0    zCQueueAdminClientCompositeOperations.delete_queue_and_wait_for_statec s|jj||fi|}|s|Sdd|D|jd}z4tj|j|j|fdfddi|}|} | WSty} ztjj|g| dWYd} ~ n d} ~ 00dS) a Calls :py:func:`~oci.queue.QueueAdminClient.purge_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest` to enter the given state(s). :param str queue_id: (required) unique Queue identifier :param oci.queue.models.PurgeQueueDetails purge_queue_details: (required) The information to be updated. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.purge_queue` :param dict waiter_kwargs: A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds`` as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait cSsg|] }|qSrr r rrrrrzVQueueAdminClientCompositeOperations.purge_queue_and_wait_for_state..rrcs t|jdot|jdvSrrrrrrrrzTQueueAdminClientCompositeOperations.purge_queue_and_wait_for_state..rN) r purge_queuer!r"r#r$r%r&r') rr(purge_queue_detailsr*r+r,r-r.r/r0r1rrrpurge_queue_and_wait_for_states$   zBQueueAdminClientCompositeOperations.purge_queue_and_wait_for_statec s|jj||fi|}|s|Sdd|D|jd}z4tj|j|j|fdfddi|}|} | WSty} ztjj|g| dWYd} ~ n d} ~ 00dS) a Calls :py:func:`~oci.queue.QueueAdminClient.update_queue` and waits for the :py:class:`~oci.queue.models.WorkRequest` to enter the given state(s). :param str queue_id: (required) unique Queue identifier :param oci.queue.models.UpdateQueueDetails update_queue_details: (required) The information to be updated. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.queue.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.queue.QueueAdminClient.update_queue` :param dict waiter_kwargs: A dictionary of keyword arguments to pass to the :py:func:`oci.wait_until` function. For example, you could pass ``max_interval_seconds`` or ``max_interval_seconds`` as dictionary keys to modify how long the waiter function will wait between retries and the maximum amount of time it will wait cSsg|] }|qSrr r rrrrrzWQueueAdminClientCompositeOperations.update_queue_and_wait_for_state..rrcs t|jdot|jdvSrrrrrrrrzUQueueAdminClientCompositeOperations.update_queue_and_wait_for_state..rN) r update_queuer!r"r#r$r%r&r') rr(update_queue_detailsr*r+r,r-r.r/r0r1rrrupdate_queue_and_wait_for_states$   zCQueueAdminClientCompositeOperations.update_queue_and_wait_for_stateN) __name__ __module__ __qualname____doc__r r2r5r8r;r>rrrrr s )&.)r)r"oci.utilrobjectrrrrrs