MaintainPull: disable retries

When MaintainPull fails the sync flow should be restarted
PeerDB-io · Feb 28, 2024 · 1e408f1 · 1e408f1
1 parent 96ca628
commit 1e408f1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -237,7 +237,7 @@ func (a *FlowableActivity) MaintainPull(
 				a.CdcCacheRw.Lock()
 				delete(a.CdcCache, sessionID)
 				a.CdcCacheRw.Unlock()
-				return err
+				return temporal.NewNonRetryableApplicationError("connection to source down", "disconnect", err)
 			}
 		case <-ctx.Done():
 			a.CdcCacheRw.Lock()

diff --git a/flow/workflows/sync_flow.go b/flow/workflows/sync_flow.go
@@ -37,13 +37,13 @@ func SyncFlowWorkflow(
 	defer workflow.CompleteSession(syncSessionCtx)
 	sessionInfo := workflow.GetSessionInfo(syncSessionCtx)
 
-	syncCtx := workflow.WithActivityOptions(syncSessionCtx, workflow.ActivityOptions{
+	maintainCtx := workflow.WithActivityOptions(syncSessionCtx, workflow.ActivityOptions{
 		StartToCloseTimeout: 14 * 24 * time.Hour,
 		HeartbeatTimeout:    time.Minute,
 		WaitForCancellation: true,
 	})
 	fMaintain := workflow.ExecuteActivity(
-		syncCtx,
+		maintainCtx,
 		flowable.MaintainPull,
 		config,
 		sessionInfo.SessionID,