don't wait 10 minutes when slot still in use

flow/workflows/cdc_flow.go

@@ -10,6 +10,7 @@ import (
 	"time"
 
 	"github.com/google/uuid"
+	"github.com/jackc/pgerrcode"
 	"go.temporal.io/api/enums/v1"
 	"go.temporal.io/sdk/log"
 	"go.temporal.io/sdk/temporal"
@@ -506,8 +507,13 @@ 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)
+			if shared.IsSQLStateError(err, pgerrcode.ObjectInUse) {
+				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")
 		}