ctx context.Context,
request DLQWriteRequest,
return e.executionManager.PutReplicationTaskToDLQ(
ctx, &persistence.PutReplicationTaskToDLQRequest{
SourceClusterName: request.SourceCluster,
// For dlq v1, this is target cluster shardID
ShardID: request.TargetShardID,
TaskInfo: request.ReplicationTaskInfo,
},
)
}
// WriteTaskToDLQ implements [DLQWriter.WriteTaskToDLQ] by calling [queues.DLQWriter.Write].