Совместная отладка задачи Celery и функции python

У меня есть класс Test в файле SampleFIle.py, который выглядит следующим образом:

Class Test:
    def m1():
       import ipdb;
       ipdb.set_trace();
       # Some logic

В том же файле у меня есть задача celery, которая выглядит следующим образом:

@shared_task()
def m1_task():
    from celery.contrib import rdb
    rdb.set_trace() 
    # some logic

Но rdb прерывается после возврата функции. Она не идет и не проверяет, что содержит m1(). Как я могу отладить как задачи celery, так и связанные с ними функции для лучшего понимания потока кодирования?

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