Find answers from the community
s
F
Y
a
P
self.state.get_task() hangs when called in a sub-threadasyncio event loop spinning.class DeferrableReActAgent(ReActAgent):
def __init__(...) -> None:
super().__init__(...)
self.agent_worker = DeferrableReActAgentWorker.from_tools(...)
self.deferral_loop = asyncio.new_event_loop()
def __start_background_loop() -> None:
asyncio.set_event_loop(self.deferral_loop)
self.deferral_loop.run_forever()
deferral_thread = Thread(target=__start_background_loop, daemon=True)
deferral_thread.start()_achat, such that -- when it deems that the it's not yet the right time to carry out a task -- it kicks off a clone of the same task in that sub-thread after 4 secs: async def _achat(...):
...
while True:
...
if cur_step_output.should_defer:
spun_off_task = self.create_task(
task.input,
extra_state=task.extra_state,
)
# Run the spun-off task after waiting for 4 seconds.
promise_to_run_task_after_wait = self._achat_from_task_after_wait(
spun_off_task
)
# Fulfill this promise in the separate thread we prepared.
asyncio.run_coroutine_threadsafe(
promise_to_run_task_after_wait, self.deferral_loop
)tool_for_backburner.py to see a proof-of-concept. The user asks the agent to walk the dog, the agent sees that the dog doesn't want to go outside because of the rain, and then the agent defers the dog-walking task to the sub-thread, returning the chat loop to the user.agent.runner.base.AgentRunner._arun_step:task = self.state.get_task(task_id)
async programming in Python, so my knowledge could only carry me this far. I'd appreciate any help on this front. Thanks!