From 8925e1d0e13f506c8b7e35b55a8fda30b9d02e97 Mon Sep 17 00:00:00 2001
From: etaques <etaques@daitan.com>
Date: Fri, 6 Oct 2023 17:22:44 -0300
Subject: [PATCH] fix: (sinker) idle message

---
 maestro/service/deploy_service.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/maestro/service/deploy_service.go b/maestro/service/deploy_service.go
index e53c84b6b..6011a9b9f 100644
--- 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 {