rebase fix

PeerDB-io · Mar 8, 2024 · 709ff15 · 709ff15
1 parent 582a821
commit 709ff15
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -608,11 +608,6 @@ func (a *FlowableActivity) replicateQRepPartition(ctx context.Context,
 	runUUID string,
 ) error {
 	logger := log.With(activity.GetLogger(ctx), slog.String(string(shared.FlowNameKey), config.FlowJobName))
-	err := monitoring.UpdateStartTimeForPartition(ctx, a.CatalogPool, runUUID, partition, time.Now())
-	if err != nil {
-		a.Alerter.LogFlowError(ctx, config.FlowJobName, err)
-		return fmt.Errorf("failed to update start time for partition: %w", err)
-	}
 
 	srcConn, err := connectors.GetQRepPullConnector(ctx, config.SourcePeer)
 	if err != nil {