bugfix
This commit is contained in:
parent
020973c7c1
commit
e2fefa8bbc
@ -1,5 +1,6 @@
|
||||
import os
|
||||
import re
|
||||
import json
|
||||
import asyncio
|
||||
import yaml
|
||||
from functools import partial
|
||||
@ -180,9 +181,9 @@ class IndustrialSkillEngine:
|
||||
|
||||
return base_content
|
||||
|
||||
async def reference(self, user_prompt:str, context: str=None, is_retry: bool=False):
|
||||
f = partial(self.run, user_prompt, context=context, is_retry=is_retry)
|
||||
asyncio.create_task(f())
|
||||
async def reference(self, params_kw):
|
||||
f = partial(self.run, params_kw)
|
||||
asyncio.create_task(self.run(params_kw))
|
||||
while True:
|
||||
data = await self.task_queue.get()
|
||||
if not data:
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user