ruạṛ
a N��f�� � @ 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 g i i fdd�Z g i i fdd�Z g i i fdd�Zg i i fdd�Zg i i fdd�Zg i i fd d �Zg i i fd d �Zg i i fd d!�Zd"S )#�*DatabaseMigrationClientCompositeOperationsa� This class provides a wrapper around :py:class:`~oci.database_migration.DatabaseMigrationClient` 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 DatabaseMigrationClientCompositeOperations object :param DatabaseMigrationClient 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/database_migration/database_migration_client_composite_operations.py�__init__ s z3DatabaseMigrationClientCompositeOperations.__init__c 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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.abort_job` and waits for the :py:class:`~oci.database_migration.models.Job` acted upon to enter the given state(s). :param str job_id: (required) The OCID of the job :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.Job.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.abort_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 ��lower��.0�wr r r � <listcomp>0 � z[DatabaseMigrationClientCompositeOperations.abort_job_and_wait_for_state.<locals>.<listcomp>�evaluate_responsec s t | jd�o t | jd��� � v S �N�lifecycle_state��getattr�datar ��r��lowered_wait_for_statesr r �<lambda>7 r zYDatabaseMigrationClientCompositeOperations.abort_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"��partial_results�causeN) r � abort_jobr �id�oci� wait_until�get_job� NameError� TypeError�args� exceptions�CompositeOperationError� Exception� r �job_id�wait_for_states�operation_kwargs� waiter_kwargs�operation_result� waiter_result�result_to_return�er r r � abort_job_and_wait_for_state s. � �� &zGDatabaseMigrationClientCompositeOperations.abort_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 ) at Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.clone_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str migration_id: (required) The OCID of the migration :param oci.database_migration.models.CloneMigrationDetails clone_migration_details: (required) Clone Migration properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.clone_migration` :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 zaDatabaseMigrationClientCompositeOperations.clone_migration_and_wait_for_state.<locals>.<listcomp>�opc-work-request-idr c s t | jd�o t | jd��� � v S �N�statusr r r r r r e r z_DatabaseMigrationClientCompositeOperations.clone_migration_and_wait_for_state.<locals>.<lambda>r N) r �clone_migration�headersr$ r% �get_work_requestr, r* r+ ) r � migration_id�clone_migration_detailsr/ r0 r1 r2 �wait_for_resource_idr3 r4 r5 r r r �"clone_migration_and_wait_for_stateE s$ � ��zMDatabaseMigrationClientCompositeOperations.clone_migration_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.database_migration.DatabaseMigrationClient.create_connection` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param oci.database_migration.models.CreateConnectionDetails create_connection_details: (required) Database Connection properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.create_connection` :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 zcDatabaseMigrationClientCompositeOperations.create_connection_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r zaDatabaseMigrationClientCompositeOperations.create_connection_and_wait_for_state.<locals>.<lambda>r N) r �create_connectionr; r$ r% r< r, r* r+ ) r �create_connection_detailsr/ r0 r1 r2 r? r3 r4 r5 r r r �$create_connection_and_wait_for_staten s$ � ��zODatabaseMigrationClientCompositeOperations.create_connection_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.database_migration.DatabaseMigrationClient.create_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param oci.database_migration.models.CreateMigrationDetails create_migration_details: (required) Migration properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.create_migration` :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 zbDatabaseMigrationClientCompositeOperations.create_migration_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r z`DatabaseMigrationClientCompositeOperations.create_migration_and_wait_for_state.<locals>.<lambda>r N) r �create_migrationr; r$ r% r< r, r* r+ ) r �create_migration_detailsr/ r0 r1 r2 r? r3 r4 r5 r r r �#create_migration_and_wait_for_state� s$ � ��zNDatabaseMigrationClientCompositeOperations.create_migration_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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_agent` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str agent_id: (required) The OCID of the agent :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_agent` :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 z^DatabaseMigrationClientCompositeOperations.delete_agent_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r z\DatabaseMigrationClientCompositeOperations.delete_agent_and_wait_for_state.<locals>.<lambda>r ) r � delete_agentr$ r* � ServiceErrorr9 r r; r% r< r, r+ ) r �agent_idr/ r0 r1 r2 r5 r? r3 r4 r r r � delete_agent_and_wait_for_state� s0 � ��zJDatabaseMigrationClientCompositeOperations.delete_agent_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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_connection` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str connection_id: (required) The OCID of the database connection :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_connection` :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 NrG c S s g | ] }|� � �qS r r r r r r r r zcDatabaseMigrationClientCompositeOperations.delete_connection_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r r zaDatabaseMigrationClientCompositeOperations.delete_connection_and_wait_for_state.<locals>.<lambda>r ) r �delete_connectionr$ r* rI r9 r r; r% r< r, r+ ) r � connection_idr/ r0 r1 r2 r5 r? r3 r4 r r r �$delete_connection_and_wait_for_state� s0 � ��zODatabaseMigrationClientCompositeOperations.delete_connection_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.database_migration.DatabaseMigrationClient.delete_job` and waits for the :py:class:`~oci.database_migration.models.Job` acted upon to enter the given state(s). :param str job_id: (required) The OCID of the job :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.Job.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_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 NrG c S s g | ] }|� � �qS r r r r r r r 5 r z\DatabaseMigrationClientCompositeOperations.delete_job_and_wait_for_state.<locals>.<listcomp>c s t | jd�o t | jd��� � v S r r r r r r r ; r zZDatabaseMigrationClientCompositeOperations.delete_job_and_wait_for_state.<locals>.<lambda>T)r �succeed_on_not_foundr r r )r r& � delete_jobr$ r* rI r9 r r% r' r( r) r+ r, ) r r. r/ r0 r1 �initial_get_resultr2 r5 r3 r4 r r r � delete_job_and_wait_for_state s< � �� &zHDatabaseMigrationClientCompositeOperations.delete_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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str migration_id: (required) The OCID of the migration :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.delete_migration` :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 NrG c S s g | ] }|� � �qS r r r r r r r h r zbDatabaseMigrationClientCompositeOperations.delete_migration_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r o r z`DatabaseMigrationClientCompositeOperations.delete_migration_and_wait_for_state.<locals>.<lambda>r ) r �delete_migrationr$ r* rI r9 r r; r% r< r, r+ ) r r= r/ r0 r1 r2 r5 r? r3 r4 r r r �#delete_migration_and_wait_for_stateJ s0 � ��zNDatabaseMigrationClientCompositeOperations.delete_migration_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.database_migration.DatabaseMigrationClient.evaluate_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str migration_id: (required) The OCID of the migration :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.evaluate_migration` :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 zdDatabaseMigrationClientCompositeOperations.evaluate_migration_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r zbDatabaseMigrationClientCompositeOperations.evaluate_migration_and_wait_for_state.<locals>.<lambda>r N) r �evaluate_migrationr; r$ r% r< r, r* r+ � r r= r/ r0 r1 r2 r? r3 r4 r5 r r r �%evaluate_migration_and_wait_for_statex s$ � ��zPDatabaseMigrationClientCompositeOperations.evaluate_migration_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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.resume_job` and waits for the :py:class:`~oci.database_migration.models.Job` acted upon to enter the given state(s). :param str job_id: (required) The OCID of the job :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.Job.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.resume_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 z\DatabaseMigrationClientCompositeOperations.resume_job_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S r r r r r r r � r zZDatabaseMigrationClientCompositeOperations.resume_job_and_wait_for_state.<locals>.<lambda>r r r N) r � resume_jobr r# r$ r% r& r' r( r) r* r+ r, r- r r r � resume_job_and_wait_for_state� s. � �� &zHDatabaseMigrationClientCompositeOperations.resume_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.database_migration.DatabaseMigrationClient.start_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str migration_id: (required) The OCID of the migration :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.start_migration` :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 zaDatabaseMigrationClientCompositeOperations.start_migration_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r z_DatabaseMigrationClientCompositeOperations.start_migration_and_wait_for_state.<locals>.<lambda>r N) r �start_migrationr; r$ r% r< r, r* r+ rV r r r �"start_migration_and_wait_for_state� s$ � ��zMDatabaseMigrationClientCompositeOperations.start_migration_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 ) aj Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.update_agent` and waits for the :py:class:`~oci.database_migration.models.Agent` acted upon to enter the given state(s). :param str agent_id: (required) The OCID of the agent :param oci.database_migration.models.UpdateAgentDetails update_agent_details: (required) Update ODMS Agent properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.Agent.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.update_agent` :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 z^DatabaseMigrationClientCompositeOperations.update_agent_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S r r r r r r r r z\DatabaseMigrationClientCompositeOperations.update_agent_and_wait_for_state.<locals>.<lambda>r r r N) r � update_agentr r# r$ r% � get_agentr' r( r) r* r+ r, ) r rJ �update_agent_detailsr/ r0 r1 r2 r3 r4 r5 r r r � update_agent_and_wait_for_state� s. � �� &zJDatabaseMigrationClientCompositeOperations.update_agent_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.database_migration.DatabaseMigrationClient.update_connection` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str connection_id: (required) The OCID of the database connection :param oci.database_migration.models.UpdateConnectionDetails update_connection_details: (required) Database Connection properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.update_connection` :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 6 r zcDatabaseMigrationClientCompositeOperations.update_connection_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r = r zaDatabaseMigrationClientCompositeOperations.update_connection_and_wait_for_state.<locals>.<lambda>r N) r �update_connectionr; r$ r% r< r, r* r+ ) r rM �update_connection_detailsr/ r0 r1 r2 r? r3 r4 r5 r r r �$update_connection_and_wait_for_state s$ � ��zODatabaseMigrationClientCompositeOperations.update_connection_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 ) aV Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.update_job` and waits for the :py:class:`~oci.database_migration.models.Job` acted upon to enter the given state(s). :param str job_id: (required) The OCID of the job :param oci.database_migration.models.UpdateJobDetails update_job_details: (required) Migration Job properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.Job.lifecycle_state` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.update_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 z\DatabaseMigrationClientCompositeOperations.update_job_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S r r r r r r r f r zZDatabaseMigrationClientCompositeOperations.update_job_and_wait_for_state.<locals>.<lambda>r r r N) r � update_jobr r# r$ r% r& r' r( r) r* r+ r, ) r r. �update_job_detailsr/ r0 r1 r2 r3 r4 r5 r r r � update_job_and_wait_for_stateF s. � �� &zHDatabaseMigrationClientCompositeOperations.update_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 ) ar Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.update_migration` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str migration_id: (required) The OCID of the migration :param oci.database_migration.models.UpdateMigrationDetails update_migration_details: (required) Migration properties. :param list[str] wait_for_states: An array of states to wait on. These should be valid values for :py:attr:`~oci.database_migration.models.WorkRequest.status` :param dict operation_kwargs: A dictionary of keyword arguments to pass to :py:func:`~oci.database_migration.DatabaseMigrationClient.update_migration` :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 zbDatabaseMigrationClientCompositeOperations.update_migration_and_wait_for_state.<locals>.<listcomp>r7 r c s t | jd�o t | jd��� � v S r8 r r r r r r � r z`DatabaseMigrationClientCompositeOperations.update_migration_and_wait_for_state.<locals>.<lambda>r N) r �update_migrationr; r$ r% r< r, r* r+ ) r r= �update_migration_detailsr/ r0 r1 r2 r? r3 r4 r5 r r r �#update_migration_and_wait_for_statet s$ � ��zNDatabaseMigrationClientCompositeOperations.update_migration_and_wait_for_stateN)�__name__� __module__� __qualname__�__doc__r r6 r@ rC rF rK rN rR rT rW rY r[ r_ rb re rh r r r r r s" +)&&..4.&+&.).r )r$ �oci.utilr �objectr r r r r �<module> s
cải xoăn