Add bookkeeping_queue when spawing Actor

vegito22 · vegito22 · commit 5f5d95d1c57e · 2024-11-04T14:29:59.000-08:00
diff --git a/llmstack/apps/runner/app_coordinator.py b/llmstack/apps/runner/app_coordinator.py
@@ -145,6 +145,7 @@ def input(self, request_id: str, data: Dict):
                         id=actor_id,
                         coordinator_urn=self.actor_urn,
                         dependencies=actor_config.dependencies,
+                        bookkeeping_queue=self._bookkeeping_queue,
                         **actor_config.kwargs,
                     )
                     self.tell_actor(

Original file line number	Diff line number	Diff line change
`@@ -145,6 +145,7 @@ def input(self, request_id: str, data: Dict):`
`145`	`145`	`id=actor_id,`
`146`	`146`	`coordinator_urn=self.actor_urn,`
`147`	`147`	`dependencies=actor_config.dependencies,`
	`148`	`+ bookkeeping_queue=self._bookkeeping_queue,`
`148`	`149`	`**actor_config.kwargs,`
`149`	`150`	`)`
`150`	`151`	`self.tell_actor(`