Update replication timestamp with no task (#3487)

* Update replication timestamp with no task * Add comment
temporalio · Oct 17, 2022 · 78366f1 · 78366f1
1 parent ff47b2c
commit 78366f1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/service/history/replication/task_processor.go b/service/history/replication/task_processor.go
@@ -478,6 +478,11 @@ func (p *taskProcessorImpl) paginationFn(_ []byte) ([]interface{}, []byte, error
 			tasks = append(tasks, task)
 		}
 		p.maxRxReceivedTaskID = resp.GetLastRetrievedMessageId()
+		if len(tasks) == 0 {
+			// Update processed timestamp to the source cluster time when there is no replication task
+			p.maxRxProcessedTimestamp = timestamp.TimeValue(resp.GetSyncShardStatus().GetStatusTime())
+		}
+
 		if resp.GetHasMore() {
 			p.rxTaskBackoff = time.Duration(0)
 		} else {