У меня есть задание по сельдерею следующим образом
@celery_app_site24x7.task(queue='site24x7')
def createWebsiteMonitoring(**kwargs):
""" Celery Task to create or update website Moniroting """
time.sleep(100)
site24x7Instance = Business_api.thirdpartyFactory.instantiate(
"site24x7")
# site24x7Instance.login()
return site24x7Instance.createWebsiteMonitoring(**kwargs)
В моем журнале работника сельдерея я могу найти, что оно успешно выполнено:
[2019-01-18 15:14: 42,633: INFO / ForkPoolWorker-2] Задача celery_tasks.site24x7.createWebsiteMonitoring [c2a5ad46-fde0-4c2c-ac46-3d2f7c9f5861] преуспела в 109.22832555975765s: '27983200000 * 100 * * 100 * * * * 1008он все еще находится в состоянии «ПОЛУЧЕНО»:
У меня проблема после добавления time.sleep(100)
Есть ли какая-либо конфигурациячто нужно добавить?Или я делаю это неправильно?
Запускаю цветок следующим образом:
flower -A monitoringExterne --app=monitoringExterne.celerys.$APP --port=8080 --broker=$CONNECTOR/$DATABASE --debug > /dev/stdout
ОБНОВЛЕНИЕ
createWebsiteMonitoring()
метод отправляет requests
POST на URL.