Часть задания celery не выполняется

Код:

    @task
    def task():
        time.sleep(10)
        a=run() #run is a long running function with string as output
        logger.critical(a)
        logger.critical("after running celery")
        return

    def view()
        logger.critical("before running celery")
        task.delay()
        return http response

Ожидаемый вывод в файле журнала:

    before running celery
    a(string stored in variable a)
    after running celery

Фактический вывод в файле журнала:

    before running celery(@time t)
    after running celery (@time t+10sec)

Не регистрируется вывод долго выполняющейся функции, который хранится в переменной a. Я даже попробовал в вышеупомянутой задаче вместо logger.critical(a)

следующим образом

    try:
        a=run() #long running function
        logger.critical("success")
    except:
        logger.critical("failure")

Все равно я получил тот же результат, ни успех, ни неудача не были зарегистрированы.

Вопросы

1. Can someone please tell me why the function is not being executed and why I am not even getting an error?
2. I am using a django-redis-celery setup so is it possible to cache the result of the function and display it onto a html page?

Вернуться на верх