@@ -63,7 +63,7 @@ class EventBus:
|
|||||||
|
|
||||||
@bus.subscribe("agent.task.*")
|
@bus.subscribe("agent.task.*")
|
||||||
async def handle_task(event: Event):
|
async def handle_task(event: Event):
|
||||||
print(f"Task event: {event.data}")
|
logger.debug(f"Task event: {event.data}")
|
||||||
|
|
||||||
await bus.publish(Event(
|
await bus.publish(Event(
|
||||||
type="agent.task.assigned",
|
type="agent.task.assigned",
|
||||||
|
|||||||
Reference in New Issue
Block a user