complete_migration async ¶

async def complete_migration(
    self,
    *,
    config_overrides: Optional[AsyncElastiCacheClientConfig] = None,
    replication_group_id: Optional["capo_elasticache.types.string.String"] = None,
    force: Optional["capo_elasticache.types.boolean.Boolean"] = None,
) -> "capo_elasticache.types.complete_migration_response.CompleteMigrationResponse":
    """<p>Complete the migration of data.</p>

    Args:
        replication_group_id: <p>The ID of the replication group to which data is being migrated.</p>
        force: <p>Forces the migration to stop without ensuring that data is in sync. It is recommended to use this option only to abort the migration and not recommended when application wants to continue migration to ElastiCache.</p>

    Raises:
        capo_elasticache.errors.invalid_replication_group_state_fault.InvalidReplicationGroupStateFault: <p>The requested replication group is not in the <code>available</code> state.</p>
        capo_elasticache.errors.replication_group_not_found_fault.ReplicationGroupNotFoundFault: <p>The specified replication group does not exist.</p>
        capo_elasticache.errors.replication_group_not_under_migration_fault.ReplicationGroupNotUnderMigrationFault: <p>The designated replication group is not available for data migration.</p>
        capo_elasticache.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_elasticache.types.complete_migration_message.CompleteMigrationMessage]",
    ) -> AsyncOperationResponse[
        "capo_elasticache.types.complete_migration_response.CompleteMigrationResponse"
    ]:
        import capo_elasticache._operations.amazon_elasti_cache_v9.complete_migration

        (
            output,
            http_response,
        ) = await capo_elasticache._operations.amazon_elasti_cache_v9.complete_migration.async_complete_migration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("CompleteMigration")
    )
    input_: capo_elasticache.types.complete_migration_message.CompleteMigrationMessage = {}
    if replication_group_id is not None:
        input_["replication_group_id"] = replication_group_id
    if force is not None:
        input_["force"] = force

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