use workflow.Now in workflows, not time.Now (#1369)

https://pkg.go.dev/go.temporal.io/sdk/workflow#Now
PeerDB-io · Feb 24, 2024 · 957e850 · 957e850
1 parent 58954df
commit 957e850
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -488,7 +488,7 @@ func CDCFlowWorkflowWithConfig(
 		}
 
 		if state.ActiveSignal == model.PauseSignal {
-			startTime := time.Now()
+			startTime := workflow.Now(ctx)
 			state.CurrentFlowStatus = protos.FlowStatus_STATUS_PAUSED
 
 			for state.ActiveSignal == model.PauseSignal {

diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go
@@ -519,7 +519,7 @@ func QRepFlowWorkflow(
 	signalChan := model.FlowSignal.GetSignalChannel(ctx)
 	q.receiveAndHandleSignalAsync(signalChan)
 	if q.activeSignal == model.PauseSignal {
-		startTime := time.Now()
+		startTime := workflow.Now(ctx)
 		state.CurrentFlowStatus = protos.FlowStatus_STATUS_PAUSED
 
 		for q.activeSignal == model.PauseSignal {

diff --git a/flow/workflows/xmin_flow.go b/flow/workflows/xmin_flow.go
@@ -89,7 +89,7 @@ func XminFlowWorkflow(
 	signalChan := model.FlowSignal.GetSignalChannel(ctx)
 	q.receiveAndHandleSignalAsync(signalChan)
 	if q.activeSignal == model.PauseSignal {
-		startTime := time.Now()
+		startTime := workflow.Now(ctx)
 		state.CurrentFlowStatus = protos.FlowStatus_STATUS_PAUSED
 
 		for q.activeSignal == model.PauseSignal {