wip

PeerDB-io · May 26, 2024 · 733aa7b · 733aa7b
1 parent b063b61
commit 733aa7b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/flow/activities/flowable_core.go b/flow/activities/flowable_core.go
@@ -144,8 +144,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon
 
 	if !hasRecords {
 		// wait for the pull goroutine to finish
-		err = errGroup.Wait()
-		if err != nil {
+		if err := errGroup.Wait(); err != nil {
 			a.Alerter.LogFlowError(ctx, flowName, err)
 			if temporal.IsApplicationError(err) {
 				return nil, err
@@ -206,8 +205,7 @@ func syncCore[TPull connectors.CDCPullConnectorCore, TSync connectors.CDCSyncCon
 		return nil
 	})
 
-	err = errGroup.Wait()
-	if err != nil {
+	if err := errGroup.Wait(); err != nil {
 		a.Alerter.LogFlowError(ctx, flowName, err)
 		if temporal.IsApplicationError(err) {
 			return nil, err