ruạṛ
a O��f)G � @ s( d dl Z d dlmZ G dd� de�ZdS )� N)�WAIT_RESOURCE_NOT_FOUNDc @ s� e Zd ZdZdd� Zg i i fdd�Zg i i fdd�Zg i i fdd �Zg i i fd d �Zg i i fd d �Z g i i fdd�Z g i i fdd�Z dS )�(StackMonitoringClientCompositeOperationsa� This class provides a wrapper around :py:class:`~oci.stack_monitoring.StackMonitoringClient` 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 c K s || _ dS )z� Creates a new StackMonitoringClientCompositeOperations object :param StackMonitoringClient client: The service client which will be wrapped by this object N)�client)�selfr �kwargs� r ��/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/oci/stack_monitoring/stack_monitoring_client_composite_operations.py�__init__ s z1StackMonitoringClientCompositeOperations.__init__c s� | j j||fi |��}|s |S dd� |D �� |jd }z4tj| j | j �|�fd� fdd�i|��}|} | W S ty� } z tjj|g| d��W Y d} ~ n d} ~ 0 0 dS ) a) Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.change_monitored_resource_compartment` and waits for the :py:class:`~oci.stack_monitoring.models.WorkRequest` to enter the given state(s). :param str monitored_resource_id: (required) The `OCID`__ of monitored resource. __ https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm :param oci.stack_monitoring.models.ChangeMonitoredResourceCompartmentDetails change_monitored_resource_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.stack_monitoring.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.change_monitored_resource_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 c S s g | ] }|� � �qS r ��lower��.0�wr r r � <listcomp>5 � zuStackMonitoringClientCompositeOperations.change_monitored_resource_compartment_and_wait_for_state.<locals>.<listcomp>�opc-work-request-id�evaluate_responsec s t | jd�o t | jd��� � v S �N�status��getattr�datar ��r��lowered_wait_for_statesr r �<lambda>< r zsStackMonitoringClientCompositeOperations.change_monitored_resource_compartment_and_wait_for_state.<locals>.<lambda>��partial_results�causeN) r �%change_monitored_resource_compartment�headers�oci� wait_until�get_work_request� Exception� exceptions�CompositeOperationError) r �monitored_resource_id�-change_monitored_resource_compartment_details�wait_for_states�operation_kwargs� waiter_kwargs�operation_result�wait_for_resource_id� waiter_result�result_to_return�er r r �8change_monitored_resource_compartment_and_wait_for_state s$ � ��zaStackMonitoringClientCompositeOperations.change_monitored_resource_compartment_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� |jj}z4tj| j | j �|�fd� fdd�i|��}|}|W S ttfy� } z6| j s�d| _ | j d | _ tj j |g| d��W Y d } ~ n>d } ~ 0 t y� } z tj j |g| d��W Y d } ~ n d } ~ 0 0 d S ) aT Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.create_discovery_job` and waits for the :py:class:`~oci.stack_monitoring.models.DiscoveryJob` acted upon to enter the given state(s). :param oci.stack_monitoring.models.CreateDiscoveryJobDetails create_discovery_job_details: (required) Summary of source and credential discovery details. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.stack_monitoring.models.DiscoveryJob.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.create_discovery_job` :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 c S s g | ] }|� � �qS r r r r r r r [ r zdStackMonitoringClientCompositeOperations.create_discovery_job_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S �N�lifecycle_stater r r r r r b r zbStackMonitoringClientCompositeOperations.create_discovery_job_and_wait_for_state.<locals>.<lambda>�� �a This composite operation is currently not supported in the SDK. Please use the operation from the service client and use waiters as an alternative. For more information on waiters, visit: "https://docs.oracle.com/en-us/iaas/tools/python/latest/api/waiters.html"r N) r �create_discovery_jobr �idr" r# �get_discovery_job� NameError� TypeError�argsr& r' r% ) r � create_discovery_job_detailsr* r+ r, r- �discovery_job_idr/ r0 r1 r r r �'create_discovery_job_and_wait_for_stateE s. � �� &zPStackMonitoringClientCompositeOperations.create_discovery_job_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� |jd }z4tj| j | j �|�fd� fdd�i|��}|}|W S ty� } z tjj|g| d��W Y d} ~ n d} ~ 0 0 dS ) a< Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.create_monitored_resource` and waits for the :py:class:`~oci.stack_monitoring.models.WorkRequest` to enter the given state(s). :param oci.stack_monitoring.models.CreateMonitoredResourceDetails create_monitored_resource_details: (required) Details for the new Resource. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.stack_monitoring.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.create_monitored_resource` :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 c S s g | ] }|� � �qS r r r r r r r � r ziStackMonitoringClientCompositeOperations.create_monitored_resource_and_wait_for_state.<locals>.<listcomp>r r c s t | jd�o t | jd��� � v S r r r r r r r � r zgStackMonitoringClientCompositeOperations.create_monitored_resource_and_wait_for_state.<locals>.<lambda>r N) r �create_monitored_resourcer! r" r# r$ r% r& r' ) r �!create_monitored_resource_detailsr* r+ r, r- r. r/ r0 r1 r r r �,create_monitored_resource_and_wait_for_statep s$ � ��zUStackMonitoringClientCompositeOperations.create_monitored_resource_and_wait_for_statec sD | j �|�}d}z| j j|fi |��}W nF tjjyn } z*|jdkrVtW Y d}~S |�W Y d}~n d}~0 0 |sx|S dd� |D �� z.tj| j |f� fdd�dd�|��}|} | W S t t f�y } z6|j s�d |_ |j d |_ tjj |g|d ��W Y d}~n@d}~0 t �y> } z tjj |g|d ��W Y d}~n d}~0 0 dS ) a� Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.delete_discovery_job` and waits for the :py:class:`~oci.stack_monitoring.models.DiscoveryJob` acted upon to enter the given state(s). :param str discovery_job_id: (required) The Discovery Job ID :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.stack_monitoring.models.DiscoveryJob.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.delete_discovery_job` :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 N� c S s g | ] }|� � �qS r r r r r r r � r zdStackMonitoringClientCompositeOperations.delete_discovery_job_and_wait_for_state.<locals>.<listcomp>c s t | jd�o t | jd��� � v S r3 r r r r r r � r zbStackMonitoringClientCompositeOperations.delete_discovery_job_and_wait_for_state.<locals>.<lambda>T)r �succeed_on_not_foundr5 r7 r )r r: �delete_discovery_jobr" r& � ServiceErrorr r r# r; r< r= r' r% ) r r? r* r+ r, �initial_get_resultr- r1 r/ r0 r r r �'delete_discovery_job_and_wait_for_state� s< � �� &zPStackMonitoringClientCompositeOperations.delete_discovery_job_and_wait_for_statec s� d}z| j j|fi |��}W nF tjjyb } z*|jdkrJtW Y d}~S |�W Y d}~n d}~0 0 |sl|S dd� |D �� |jd }z4tj| j | j � |�fd� fdd�i|��}|} | W S t y� } z tjj |g|d ��W Y d}~n d}~0 0 dS ) aV Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.delete_monitored_resource` and waits for the :py:class:`~oci.stack_monitoring.models.WorkRequest` to enter the given state(s). :param str monitored_resource_id: (required) The `OCID`__ of monitored resource. __ https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.stack_monitoring.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.delete_monitored_resource` :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 NrD c S s g | ] }|� � �qS r r r r r r r � r ziStackMonitoringClientCompositeOperations.delete_monitored_resource_and_wait_for_state.<locals>.<listcomp>r r c s t | jd�o t | jd��� � v S r r r r r r r � r zgStackMonitoringClientCompositeOperations.delete_monitored_resource_and_wait_for_state.<locals>.<lambda>r ) r �delete_monitored_resourcer" r& rG r r r! r# r$ r% r' ) r r( r* r+ r, r- r1 r. r/ r0 r r r �,delete_monitored_resource_and_wait_for_state� s0 � ��zUStackMonitoringClientCompositeOperations.delete_monitored_resource_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� |jd }z4tj| j | j �|�fd� fdd�i|��}|}|W S ty� } z tjj|g| d��W Y d} ~ n d} ~ 0 0 dS ) aV Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.disable_external_database` and waits for the :py:class:`~oci.stack_monitoring.models.WorkRequest` to enter the given state(s). :param str monitored_resource_id: (required) The `OCID`__ of monitored resource. __ https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.stack_monitoring.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.disable_external_database` :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 c S s g | ] }|� � �qS r r r r r r r r ziStackMonitoringClientCompositeOperations.disable_external_database_and_wait_for_state.<locals>.<listcomp>r r c s t | jd�o t | jd��� � v S r r r r r r r r zgStackMonitoringClientCompositeOperations.disable_external_database_and_wait_for_state.<locals>.<lambda>r N) r �disable_external_databaser! r" r# r$ r% r& r' ) r r( r* r+ r, r- r. r/ r0 r1 r r r �,disable_external_database_and_wait_for_state� s$ � ��zUStackMonitoringClientCompositeOperations.disable_external_database_and_wait_for_statec s� | j j||fi |��}|s |S dd� |D �� |jd }z4tj| j | j �|�fd� fdd�i|��}|} | W S ty� } z tjj|g| d��W Y d} ~ n d} ~ 0 0 dS ) a� Calls :py:func:`~oci.stack_monitoring.StackMonitoringClient.update_monitored_resource` and waits for the :py:class:`~oci.stack_monitoring.models.WorkRequest` to enter the given state(s). :param str monitored_resource_id: (required) The `OCID`__ of monitored resource. __ https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm :param oci.stack_monitoring.models.UpdateMonitoredResourceDetails update_monitored_resource_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.stack_monitoring.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.stack_monitoring.StackMonitoringClient.update_monitored_resource` :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 c S s g | ] }|� � �qS r r r r r r r = r ziStackMonitoringClientCompositeOperations.update_monitored_resource_and_wait_for_state.<locals>.<listcomp>r r c s t | jd�o t | jd��� � v S r r r r r r r D r zgStackMonitoringClientCompositeOperations.update_monitored_resource_and_wait_for_state.<locals>.<lambda>r N) r �update_monitored_resourcer! r" r# r$ r% r& r' ) r r( �!update_monitored_resource_detailsr* r+ r, r- r. r/ r0 r1 r r r �,update_monitored_resource_and_wait_for_state" s$ � ��zUStackMonitoringClientCompositeOperations.update_monitored_resource_and_wait_for_stateN) �__name__� __module__� __qualname__�__doc__r r2 r@ rC rI rK rM rP r r r r r s ++&40(r )r" �oci.utilr �objectr r r r r �<module> s
cải xoăn