fix: (sinker) idle message

orb-community · Oct 6, 2023 · 8925e1d · 8925e1d
1 parent ff54b67
commit 8925e1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/maestro/service/deploy_service.go b/maestro/service/deploy_service.go
@@ -149,7 +149,7 @@ func (d *eventService) HandleSinkIdle(ctx context.Context, event maestroredis.Si
 		if err != nil {
 			d.logger.Error("error updating status to idle", zap.Error(err))
 		}
-	}
+	}()
 	// dropping idle otel collector
 	_, err := d.deploymentService.NotifyCollector(ctx, event.OwnerID, event.SinkID, "delete", "", "")
 	if err != nil {