/
usr
/
lib
/
python3.9
/
site-packages
/
oci
/
database_migration
/
__pycache__
/
Upload File
HOME
a ���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!�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 �i/usr/lib/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>1 � z[DatabaseMigrationClientCompositeOperations.abort_job_and_wait_for_state.<locals>.<listcomp>�evaluate_responsec s t | jd�o t | jd��� � v S �NZlifecycle_state��getattr�datar ��r�Zlowered_wait_for_statesr r �<lambda>8 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"�Zpartial_results�causeN) r Z 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 �� d|jvr:|S |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 g r z_DatabaseMigrationClientCompositeOperations.clone_migration_and_wait_for_state.<locals>.<lambda>r N) r Zclone_migration�headersr r! �get_work_requestr( r& r' ) r � migration_idZclone_migration_detailsr+ r, r- r. �wait_for_resource_idr/ r0 r1 r r r �"clone_migration_and_wait_for_stateF s( � ��zMDatabaseMigrationClientCompositeOperations.clone_migration_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� d|jvr8|S |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>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r zaDatabaseMigrationClientCompositeOperations.create_connection_and_wait_for_state.<locals>.<lambda>r N) r Zcreate_connectionr6 r r! r7 r( r& r' ) r Zcreate_connection_detailsr+ r, r- r. r9 r/ r0 r1 r r r �$create_connection_and_wait_for_statep s( � ��zODatabaseMigrationClientCompositeOperations.create_connection_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� d|jvr8|S |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>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r z`DatabaseMigrationClientCompositeOperations.create_migration_and_wait_for_state.<locals>.<lambda>r N) r Zcreate_migrationr6 r r! r7 r( r& r' ) r Zcreate_migration_detailsr+ r, r- r. r9 r/ r0 r1 r r r �#create_migration_and_wait_for_state� s( � ��zNDatabaseMigrationClientCompositeOperations.create_migration_and_wait_for_statec s� | j j||fi |��}|s |S dd� |D �� d|jvr:|S |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_parameter_file_version` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str job_id: (required) The OCID of the job :param oci.database_migration.models.CreateParameterFileVersionDetails create_parameter_file_version_details: (required) The parameter file version details to be created :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_parameter_file_version` :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 zoDatabaseMigrationClientCompositeOperations.create_parameter_file_version_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r zmDatabaseMigrationClientCompositeOperations.create_parameter_file_version_and_wait_for_state.<locals>.<lambda>r N) r Z create_parameter_file_versionr6 r r! r7 r( r& r' ) r r* Z%create_parameter_file_version_detailsr+ r, r- r. r9 r/ r0 r1 r r r �0create_parameter_file_version_and_wait_for_state� s( � ��z[DatabaseMigrationClientCompositeOperations.create_parameter_file_version_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 �� d|jvr�|S |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 N� c S s g | ] }|� � �qS r r r r r r r r zcDatabaseMigrationClientCompositeOperations.delete_connection_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r r zaDatabaseMigrationClientCompositeOperations.delete_connection_and_wait_for_state.<locals>.<lambda>r ) r Zdelete_connectionr r& � ServiceErrorr5 r r6 r! r7 r( r' ) r � connection_idr+ r, r- r. r1 r9 r/ r0 r r r �$delete_connection_and_wait_for_state� s4 � ��zODatabaseMigrationClientCompositeOperations.delete_connection_and_wait_for_statec sr | 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 �� zZd|v r�|d du r�| j jj � d� nd|d< tj | j |fd � fd d �i|��}|} | W S t t f�y6 } z8|j�sd |_|jd |_tjj|g|d��W Y d}~n@d}~0 t�yl } 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 Nr> c S s g | ] }|� � �qS r r r r r r r 5 r z\DatabaseMigrationClientCompositeOperations.delete_job_and_wait_for_state.<locals>.<listcomp>Zsucceed_on_not_foundFz�The waiter kwarg succeed_on_not_found was passed as False for the delete composite operation delete_job, this would result in the operation to fail if the resource is not found! Please, do not pass this kwarg if this was not intendedTr c s t | jd�o t | jd��� � v S r r r r r r r D r zZDatabaseMigrationClientCompositeOperations.delete_job_and_wait_for_state.<locals>.<lambda>r r r )r r" Z delete_jobr r& r? r5 r Z base_client�loggerZwarningr! r# r$ r% r' r( ) r r* r+ r, r- Zinitial_get_resultr. r1 r/ r0 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 �� d|jvr�|S |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 Nr> c S s g | ] }|� � �qS r r r r r r r o r zbDatabaseMigrationClientCompositeOperations.delete_migration_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r x r z`DatabaseMigrationClientCompositeOperations.delete_migration_and_wait_for_state.<locals>.<lambda>r ) r Zdelete_migrationr r& r? r5 r r6 r! r7 r( r' ) r r8 r+ r, r- r. r1 r9 r/ r0 r r r �#delete_migration_and_wait_for_stateR s4 � ��zNDatabaseMigrationClientCompositeOperations.delete_migration_and_wait_for_statec s d}z| j j||fi |��}W nF tjjyd } z*|jdkrLtW Y d}~S |�W Y d}~n d}~0 0 |sn|S dd� |D �� d|jvr�|S |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_parameter_file_version` and waits for the :py:class:`~oci.database_migration.models.WorkRequest` to enter the given state(s). :param str job_id: (required) The OCID of the job :param str parameter_file_name: (required) A unique name associated with the current migration/job and extract/replicat name :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_parameter_file_version` :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 Nr> c S s g | ] }|� � �qS r r r r r r r � r zoDatabaseMigrationClientCompositeOperations.delete_parameter_file_version_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r zmDatabaseMigrationClientCompositeOperations.delete_parameter_file_version_and_wait_for_state.<locals>.<lambda>r ) r Z delete_parameter_file_versionr r& r? r5 r r6 r! r7 r( r' ) r r* �parameter_file_namer+ r, r- r. r1 r9 r/ r0 r r r �0delete_parameter_file_version_and_wait_for_state� s4 � ��z[DatabaseMigrationClientCompositeOperations.delete_parameter_file_version_and_wait_for_statec s� | j j|fi |��}|s |S dd� |D �� d|jvr8|S |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>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r zbDatabaseMigrationClientCompositeOperations.evaluate_migration_and_wait_for_state.<locals>.<lambda>r N) r Zevaluate_migrationr6 r r! r7 r( r& r' � r r8 r+ r, r- r. r9 r/ r0 r1 r r r �%evaluate_migration_and_wait_for_state� 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.make_current_parameter_file_version` 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 str parameter_file_name: (required) A unique name associated with the current migration/job and extract/replicat name :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.make_current_parameter_file_version` :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 zuDatabaseMigrationClientCompositeOperations.make_current_parameter_file_version_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S r r r r r r r � r zsDatabaseMigrationClientCompositeOperations.make_current_parameter_file_version_and_wait_for_state.<locals>.<lambda>r r r N) r Z#make_current_parameter_file_versionr r r r! r" r# r$ r% r& r' r( ) r r* rE r+ r, r- r. r/ r0 r1 r r r �6make_current_parameter_file_version_and_wait_for_state� s. � �� &zaDatabaseMigrationClientCompositeOperations.make_current_parameter_file_version_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 Z 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 �� d|jvr8|S |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 F r zaDatabaseMigrationClientCompositeOperations.start_migration_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r O r z_DatabaseMigrationClientCompositeOperations.start_migration_and_wait_for_state.<locals>.<lambda>r N) r Zstart_migrationr6 r r! r7 r( r& r' rG r r r �"start_migration_and_wait_for_state1 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 ) a� Calls :py:func:`~oci.database_migration.DatabaseMigrationClient.suspend_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.suspend_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 m r z]DatabaseMigrationClientCompositeOperations.suspend_job_and_wait_for_state.<locals>.<listcomp>r c s t | jd�o t | jd��� � v S r r r r r r r t r z[DatabaseMigrationClientCompositeOperations.suspend_job_and_wait_for_state.<locals>.<lambda>r r r N) r Z suspend_jobr r r r! r" r# r$ r% r& r' r( r) r r r � suspend_job_and_wait_for_stateX s. � �� &zIDatabaseMigrationClientCompositeOperations.suspend_job_and_wait_for_statec s� | j j||fi |��}|s |S dd� |D �� d|jvr:|S |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 � r zcDatabaseMigrationClientCompositeOperations.update_connection_and_wait_for_state.<locals>.<listcomp>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r zaDatabaseMigrationClientCompositeOperations.update_connection_and_wait_for_state.<locals>.<lambda>r N) r Zupdate_connectionr6 r r! r7 r( r& r' ) r r@ Zupdate_connection_detailsr+ r, r- r. r9 r/ r0 r1 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 � r zZDatabaseMigrationClientCompositeOperations.update_job_and_wait_for_state.<locals>.<lambda>r r r N) r Z update_jobr r r r! r" r# r$ r% r& r' r( ) r r* Zupdate_job_detailsr+ r, r- r. r/ r0 r1 r r r � update_job_and_wait_for_state� s. � �� &zHDatabaseMigrationClientCompositeOperations.update_job_and_wait_for_statec s� | j j||fi |��}|s |S dd� |D �� d|jvr:|S |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>r3 r c s t | jd�o t | jd��� � v S r4 r r r r r r � r z`DatabaseMigrationClientCompositeOperations.update_migration_and_wait_for_state.<locals>.<lambda>r N) r Zupdate_migrationr6 r r! r7 r( r& r' ) r r8 Zupdate_migration_detailsr+ r, r- r. r9 r/ r0 r1 r r r �#update_migration_and_wait_for_state� s( � ��zNDatabaseMigrationClientCompositeOperations.update_migration_and_wait_for_stateN)�__name__� __module__� __qualname__�__doc__r r2 r: r; r< r= rA rC rD rF rH rI rJ rK rL rM rN rO r r r r r s& **''*/;/2'-*'**-r )r Zoci.utilr �objectr r r r r �<module> s