fix _consume_run check

This commit is contained in:
Reinier van der Leer
2026-02-12 15:23:18 +01:00
parent 6e2f595c7d
commit ab25516a46

View File

@@ -221,7 +221,7 @@ class CoPilotExecutor(AppProcess):
self.run_client.connect()
# Check again after connect - shutdown may have been requested
if self.stop_consuming.is_set() and not self.active_tasks:
if self.stop_consuming.is_set():
logger.info("Stop consuming requested during reconnect - disconnecting")
self.run_client.disconnect()
return