Move reading PEERDB_DISABLE_ONE_SYNC into side effect

PeerDB-io · Mar 15, 2024 · 908c63c · 908c63c
1 parent 244c095
commit 908c63c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go
@@ -28,9 +28,12 @@ func SyncFlowWorkflow(
 	parent := workflow.GetInfo(ctx).ParentWorkflowExecution
 	logger := log.With(workflow.GetLogger(ctx), slog.String(string(shared.FlowNameKey), config.FlowJobName))
 
+	disableOneSync := GetSideEffect(ctx, func(_ workflow.Context) bool {
+		return peerdbenv.PeerDBDisableOneSync()
+	})
 	var fMaintain workflow.Future
 	var sessionID string
-	if !peerdbenv.PeerDBDisableOneSync() {
+	if !disableOneSync {
 		sessionOptions := &workflow.SessionOptions{
 			CreationTimeout:  5 * time.Minute,
 			ExecutionTimeout: 144 * time.Hour,