Я использую celery-flask для постановки в очередь и мониторинга задачи, у меня есть от четырех до пяти сценариев, и я хочу, чтобы эти сценарии выполнялись как задача celery, передавая сценарий через сервер flask, а затем отслеживая их состояние. Вот код, который я написал до сих пор:
@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}
я хочу, чтобы статус сценария, переданный в результате, возвращался в задаче сельдерея.
если у кого-нибудь есть другое предложение, как запустить внешнюю задачу как задачу сельдерея. заранее спасибо.
