no retries, handle retry timeout ourselves

PeerDB-io · Dec 24, 2024 · 85dbc04 · 85dbc04
1 parent 81bd73c
commit 85dbc04
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -100,6 +100,8 @@ func processCDCFlowConfigUpdate(
 	}
 	if flowConfigUpdate.NumberOfSyncs > 0 {
 		state.SyncFlowOptions.NumberOfSyncs = flowConfigUpdate.NumberOfSyncs
+	} else if flowConfigUpdate.NumberOfSyncs < 0 {
+		state.SyncFlowOptions.NumberOfSyncs = 0
 	}
 	if flowConfigUpdate.UpdatedEnv != nil {
 		maps.Copy(cfg.Env, flowConfigUpdate.UpdatedEnv)
@@ -478,9 +480,7 @@ func CDCFlowWorkflow(
 		StartToCloseTimeout: 365 * 24 * time.Hour,
 		HeartbeatTimeout:    time.Minute,
 		WaitForCancellation: true,
-		RetryPolicy: &temporal.RetryPolicy{
-			InitialInterval: 30 * time.Second,
-		},
+		RetryPolicy:         &temporal.RetryPolicy{MaximumAttempts: 1},
 	})
 	syncFlowFuture := workflow.ExecuteActivity(syncCtx, flowable.SyncFlow, cfg, state.SyncFlowOptions)
 
@@ -500,6 +500,7 @@ func CDCFlowWorkflow(
 			} else {
 				logger.Error("error in sync flow", slog.Any("error", err))
 			}
+			_ = workflow.Sleep(ctx, 30*time.Second)
 		} else {
 			logger.Info("sync finished")
 		}