fix: err checking

PeerDB-io · Nov 14, 2024 · c382119 · c382119
1 parent 17f8c61
commit c382119
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/flow/activities/maintenance_activity.go b/flow/activities/maintenance_activity.go
@@ -153,9 +153,13 @@ func (a *MaintenanceActivity) PauseMirrorIfRunning(ctx context.Context, mirror *
 
 	return RunEveryIntervalUntilFinish(ctx, func() (bool, bool, error) {
 		updatedMirrorStatus, statusErr := a.getMirrorStatus(ctx, mirror)
+		if statusErr != nil {
+			return false, false, statusErr
+		}
 		activity.RecordHeartbeat(ctx, "Waiting for mirror to pause with current status "+updatedMirrorStatus.String())
-		if err := model.FlowSignal.SignalClientWorkflow(ctx, a.TemporalClient, mirror.WorkflowId, "", model.PauseSignal); statusErr != nil {
-			return false, false, err
+		if statusErr := model.FlowSignal.SignalClientWorkflow(ctx, a.TemporalClient, mirror.WorkflowId, "",
+			model.PauseSignal); statusErr != nil {
+			return false, false, statusErr
 		}
 		if updatedMirrorStatus == protos.FlowStatus_STATUS_PAUSED {
 			return true, true, nil