don't wait 10 minutes when slot still in use

PeerDB-io · Jan 9, 2025 · 8d6244a · 8d6244a
1 parent 980eb42
commit 8d6244a
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -506,8 +506,15 @@ func CDCFlowWorkflow(
 			} else {
 				logger.Error("error in sync flow", slog.Any("error", err))
 			}
-			logger.Info("sync flow errored, sleeping for 10 minutes before retrying")
-			_ = workflow.Sleep(ctx, 10*time.Minute)
+
+			// cannot use shared.IsSQLStateError because temporal serialize/deserialize
+			if strings.Contains(err.Error(), "(SQLSTATE 55006)") {
+				logger.Info("sync flow errored, sleeping for 1 minute before retrying")
+				_ = workflow.Sleep(ctx, time.Minute)
+			} else {
+				logger.Info("sync flow errored, sleeping for 10 minutes before retrying")
+				_ = workflow.Sleep(ctx, 10*time.Minute)
+			}
 		} else {
 			logger.Info("sync finished")
 		}