remove comment

PeerDB-io · Jan 17, 2025 · 4eefa08 · 4eefa08
1 parent def119a
commit 4eefa08
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -428,11 +428,7 @@ func CDCFlowWorkflow(
 			WaitForCancellation:   true,
 		}
 		snapshotFlowCtx := workflow.WithChildOptions(ctx, childSnapshotFlowOpts)
-		snapshotFlowFuture := workflow.ExecuteChildWorkflow(
-			snapshotFlowCtx,
-			SnapshotFlowWorkflow,
-			cfg,
-		)
+		snapshotFlowFuture := workflow.ExecuteChildWorkflow(snapshotFlowCtx, SnapshotFlowWorkflow, cfg)
 		if err := snapshotFlowFuture.Get(snapshotFlowCtx, nil); err != nil {
 			logger.Error("snapshot flow failed", slog.Any("error", err))
 			return state, fmt.Errorf("failed to execute snapshot workflow: %w", err)

diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go
@@ -32,7 +32,6 @@ type SnapshotFlowExecution struct {
 	logger log.Logger
 }
 
-// ensurePullability ensures that the source peer is pullable.
 func (s *SnapshotFlowExecution) setupReplication(
 	ctx workflow.Context,
 ) (*protos.SetupReplicationOutput, error) {