retry_data_replication async ¶

async def retry_data_replication(
    self,
    source_server_id: "capo_mgn.types.source_server_id.SourceServerID",
    *,
    config_overrides: Optional[AsyncmgnClientConfig] = None,
    account_id: Optional["capo_mgn.types.account_id.AccountID"] = None,
) -> "capo_mgn.types.source_server.SourceServer":
    """<p>Causes the data replication initiation sequence to begin immediately upon next Handshake for specified SourceServer IDs, regardless of when the previous initiation started. This command will not work if the SourceServer is not stalled or is in a DISCONNECTED or STOPPED state.</p>

    Args:
        source_server_id: <p>Retry data replication for Source Server ID.</p>
        account_id: <p>Retry data replication for Account ID.</p>

    Raises:
        capo_mgn.errors.resource_not_found_exception.ResourceNotFoundException: <p>Resource not found exception.</p>
        capo_mgn.errors.uninitialized_account_exception.UninitializedAccountException: <p>Uninitialized account exception.</p>
        capo_mgn.errors.validation_exception.ValidationException: <p>Validate exception.</p>
        capo_mgn.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_mgn.types.retry_data_replication_request.RetryDataReplicationRequest]",
    ) -> AsyncOperationResponse["capo_mgn.types.source_server.SourceServer"]:
        import capo_mgn._operations.application_migration_service.retry_data_replication

        (
            output,
            http_response,
        ) = await capo_mgn._operations.application_migration_service.retry_data_replication.async_retry_data_replication(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_output(
        output: "capo_mgn.types.source_server.SourceServer",
    ) -> dict[str, Any]:
        import capo_mgn.types.source_server

        return capo_mgn.types.source_server.redact_sensitive(output)

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("RetryDataReplication", redact_output=_redact_output),
    )
    input_: capo_mgn.types.retry_data_replication_request.RetryDataReplicationRequest = {
        "source_server_id": source_server_id
    }
    if account_id is not None:
        input_["account_id"] = account_id

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