call SyncFlowCleanup during SetupFlow (#2464)

PeerDB-io · Jan 20, 2025 · 304f4f1 · 304f4f1
1 parent 99b8b8f
commit 304f4f1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -83,6 +83,13 @@ func (a *FlowableActivity) SetupMetadataTables(ctx context.Context, config *prot
 		return fmt.Errorf("failed to setup metadata tables: %w", err)
 	}
 
+	// this should have been done by DropFlowDestination
+	// but edge case due to late context cancellation
+	if err := dstConn.SyncFlowCleanup(ctx, config.FlowName); err != nil {
+		a.Alerter.LogFlowError(ctx, config.FlowName, err)
+		return fmt.Errorf("failed to clean up destination before mirror setup: %w", err)
+	}
+
 	return nil
 }