Update prefixes in cli (#84)

callumforrester · web-flow · commit b3326a32b4ae · 2023-01-27T14:46:07.000Z
diff --git a/src/blueapi/cli/amq.py b/src/blueapi/cli/amq.py
@@ -37,7 +37,7 @@ def on_event_wrapper(ctx: MessageContext, event: TaskEvent) -> None:
                 complete.set()
 
         self.app.subscribe(
-            self.app.destinations.topic("worker.event.task"), on_event_wrapper
+            self.app.destinations.topic("public.worker.event.task"), on_event_wrapper
         )
         # self.app.send("worker.run", {"name": name, "params": params})
         task_id = self.app.send_and_recieve(

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ def on_event_wrapper(ctx: MessageContext, event: TaskEvent) -> None:`
`37`	`37`	`complete.set()`
`38`	`38`
`39`	`39`	`self.app.subscribe(`
`40`		`- self.app.destinations.topic("worker.event.task"), on_event_wrapper`
	`40`	`+ self.app.destinations.topic("public.worker.event.task"), on_event_wrapper`
`41`	`41`	`)`
`42`	`42`	`# self.app.send("worker.run", {"name": name, "params": params})`
`43`	`43`	`task_id = self.app.send_and_recieve(`