retry_data_replication ¶

def retry_data_replication(
    self,
    source_server_id: "capo_mgn.types.source_server_id.SourceServerID",
    *,
    config_overrides: Optional[mgnClientConfig] = 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.
    """

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

        output, http_response = (
            capo_mgn._operations.application_migration_service.retry_data_replication.retry_data_replication(
                req.options, req.input
            )
        )
        return OperationResponse(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 = execute_pipeline(
        OperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    response.response.close()
    return response.output