Я использую celery-flask для постановки в очередь и наблюдения за задачей, у меня есть четыре-пять сценариев, и я хочу, чтобы эти сценарии выполнялись как задача celery, передавая сценарий через флеш-сервер и затем отслеживая их состояние.
Вот код, который я написал до сих пор:
@app.route('/script_path/<script_name>') # flask server
def taking_script_name(script_name):
calling_script.delay(script_name)
return 'i have sent an async script request'
@celery.task
def calling_script(script_name):
result = script_name
return {'result':result}
Я хочу, чтобы статус сценария передавался в результате, возвращаемом в задаче сельдерея.
если у кого-то есть другое предложение, как запустить внешнюю задачу как задачу сельдерея.
заранее спасибо.