mirror of https://github.com/corca-ai/EVAL
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
43 lines
1.0 KiB
Python
43 lines
1.0 KiB
Python
from celery import Celery
|
|
from celery.result import AsyncResult
|
|
|
|
from api.container import agent_manager
|
|
from env import settings
|
|
|
|
celery_app = Celery(__name__)
|
|
celery_app.conf.broker_url = settings["CELERY_BROKER_URL"]
|
|
celery_app.conf.result_backend = settings["CELERY_BROKER_URL"]
|
|
celery_app.conf.update(
|
|
task_track_started=True,
|
|
task_serializer="json",
|
|
accept_content=["json"], # Ignore other content
|
|
result_serializer="json",
|
|
enable_utc=True,
|
|
)
|
|
|
|
|
|
@celery_app.task(name="task_execute", bind=True)
|
|
def task_execute(self, session: str, prompt: str):
|
|
executor = agent_manager.create_executor(session, self)
|
|
response = executor({"input": prompt})
|
|
result = {"output": response["output"]}
|
|
|
|
previous = AsyncResult(self.request.id)
|
|
if previous and previous.info:
|
|
result.update(previous.info)
|
|
|
|
return result
|
|
|
|
|
|
def get_task_result(task_id):
|
|
return AsyncResult(task_id)
|
|
|
|
|
|
def start_worker():
|
|
celery_app.worker_main(
|
|
[
|
|
"worker",
|
|
"--loglevel=INFO",
|
|
]
|
|
)
|