start_replication_task_assessment `async` ¶

start_replication_task_assessment(
    replication_task_arn: String,
    *,
    config_overrides: Optional[AsyncDatabaseMigrationServiceClientConfig] = None,
) -> StartReplicationTaskAssessmentResponse

Starts the replication task assessment for unsupported data types in the source database.

You can only use this operation for a task if the following conditions are true:

The task must be in the stopped state.
The task must have successful connections to the source and target.

If either of these conditions are not met, an InvalidResourceStateFault error will result.

For information about DMS task assessments, see Creating a task assessment report in the Database Migration Service User Guide.

Parameters:

replication_task_arn (String) –

The Amazon Resource Name (ARN) of the replication task.

Raises:

InvalidResourceStateFault –

The resource is in a state that prevents it from being used for database migration.
ResourceNotFoundFault –

The resource could not be found.
UnknownServiceError –

The service returned an error code this client does not model.

Source code in docs_src/capo_database_migration_service/_services/async_database_migration_service.py

async def start_replication_task_assessment(
    self,
    replication_task_arn: "capo_database_migration_service.types.string.String",
    *,
    config_overrides: Optional[AsyncDatabaseMigrationServiceClientConfig] = None,
) -> "capo_database_migration_service.types.start_replication_task_assessment_response.StartReplicationTaskAssessmentResponse":
    """<p> Starts the replication task assessment for unsupported data types in the source database. </p> <p>You can only use this operation for a task if the following conditions are true:</p> <ul> <li> <p>The task must be in the <code>stopped</code> state.</p> </li> <li> <p>The task must have successful connections to the source and target.</p> </li> </ul> <p>If either of these conditions are not met, an <code>InvalidResourceStateFault</code> error will result. </p> <p>For information about DMS task assessments, see <a href="https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.AssessmentReport.html">Creating a task assessment report</a> in the <i>Database Migration Service User Guide</i>.</p>

    Args:
        replication_task_arn: <p> The Amazon Resource Name (ARN) of the replication task. </p>

    Raises:
        capo_database_migration_service.errors.invalid_resource_state_fault.InvalidResourceStateFault: <p>The resource is in a state that prevents it from being used for database migration.</p>
        capo_database_migration_service.errors.resource_not_found_fault.ResourceNotFoundFault: <p>The resource could not be found.</p>
        capo_database_migration_service.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_database_migration_service.types.start_replication_task_assessment_message.StartReplicationTaskAssessmentMessage]",
    ) -> AsyncOperationResponse[
        "capo_database_migration_service.types.start_replication_task_assessment_response.StartReplicationTaskAssessmentResponse"
    ]:
        import capo_database_migration_service._operations.amazon_dm_sv20160101.start_replication_task_assessment

        (
            output,
            http_response,
        ) = await capo_database_migration_service._operations.amazon_dm_sv20160101.start_replication_task_assessment.async_start_replication_task_assessment(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("StartReplicationTaskAssessment")
    )
    input_: capo_database_migration_service.types.start_replication_task_assessment_message.StartReplicationTaskAssessmentMessage = {
        "replication_task_arn": replication_task_arn
    }

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output

start_replication_task_assessment async ¶

start_replication_task_assessment `async` ¶