retry_data_replication ¶

def retry_data_replication(
    self,
    source_server_id: "capo_drs.types.source_server_id.SourceServerID",
    *,
    config_overrides: Optional[drsClientConfig] = None,
) -> "capo_drs.types.source_server.SourceServer":
    """<p>WARNING: RetryDataReplication is deprecated. Causes the data replication initiation sequence to begin immediately upon next Handshake for the specified Source Server ID, regardless of when the previous initiation started. This command will work only if the Source Server is stalled or is in a DISCONNECTED or STOPPED state. </p>

    Args:
        source_server_id: <p>The ID of the Source Server whose data replication should be retried.</p>

    Raises:
        capo_drs.errors.internal_server_exception.InternalServerException: <p>The request processing has failed because of an unknown error, exception or failure.</p>
        capo_drs.errors.resource_not_found_exception.ResourceNotFoundException: <p>The resource for this operation was not found.</p>
        capo_drs.errors.throttling_exception.ThrottlingException: <p>The request was denied due to request throttling.</p>
        capo_drs.errors.uninitialized_account_exception.UninitializedAccountException: <p>The account performing the request has not been initialized.</p>
        capo_drs.errors.validation_exception.ValidationException: <p>The input fails to satisfy the constraints specified by the AWS service.</p>
        capo_drs.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

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

        output, http_response = (
            capo_drs._operations.elastic_disaster_recovery_service.retry_data_replication.retry_data_replication(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

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

        return capo_drs.types.source_server.redact_sensitive(output)

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("RetryDataReplication", redact_output=_redact_output),
    )
    input_: capo_drs.types.retry_data_replication_request.RetryDataReplicationRequest = {
        "source_server_id": source_server_id
    }

    response = execute_pipeline(
        OperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    response.response.close()
    return response.output