Add logging when dumping in dlq
@@ -514,6 +514,13 @@ func (t *workflowReplicationTask) Nack() {
t.metricsClient.IncCounter(t.metricsScope, metrics.ReplicatorMessages)
t.metricsClient.RecordTimer(t.metricsScope, metrics.ReplicatorLatency, t.timeSource.Now().Sub(t.startTime))
+ t.logger.Info("Replication task moved to DLQ",
+ tag.WorkflowDomainID(t.queueID.DomainID),
+ tag.WorkflowID(t.queueID.WorkflowID),
+ tag.WorkflowRunID(t.queueID.RunID),
+ tag.TaskID(t.taskID),
+ )
+
t.state = task.TaskStateNacked
// the underlying implementation will not return anything other than nil
// do logging just in case
