make messages consistent

This commit is contained in:
Reinier van der Leer
2026-02-16 17:34:54 +01:00
parent 8fe47bd999
commit 639e4d6fd3

View File

@@ -216,7 +216,7 @@ class CoPilotExecutor(AppProcess):
on_message_callback=self._handle_cancel_message,
auto_ack=True,
)
logger.info("Starting cancel message consumer...")
logger.info("Starting to consume cancel messages...")
cancel_channel.start_consuming()
if not self.stop_consuming.is_set() or self.active_tasks:
raise RuntimeError("Cancel message consumer stopped unexpectedly")