fix(scheduler): prevent DisconnectedProducerError

aarthy-dk · aarthy-dk · commit d99bab18b255 · 2025-03-03T18:35:25.000-05:00
diff --git a/scheduler/agent_check.py b/scheduler/agent_check.py
@@ -90,5 +90,4 @@ def _send_agent_status_change_event(self, agent: Agent, new_status: AgentStatus)
             latest_event_timestamp=agent.latest_event_timestamp,
         )
 
-        with self.event_producer as producer:
-            producer.produce(self.kafka_topic, event)
+        self.event_producer.produce(self.kafka_topic, event)

Original file line number	Diff line number	Diff line change
`@@ -90,5 +90,4 @@ def _send_agent_status_change_event(self, agent: Agent, new_status: AgentStatus)`
`90`	`90`	`latest_event_timestamp=agent.latest_event_timestamp,`
`91`	`91`	`)`
`92`	`92`
`93`		`- with self.event_producer as producer:`
`94`		`- producer.produce(self.kafka_topic, event)`
	`93`	`+ self.event_producer.produce(self.kafka_topic, event)`