Django Celery IntegrityError

Я хочу создать индикатор выполнения для своего проекта. У меня есть класс, и этот класс имеет несколько функций. Особенно одна из них занимает много времени (def download_all), и это моя основная причина, по которой я хочу создать индикатор выполнения.

Я успешно установил celery, celery-progress и т.д., и они работают нормально. Моя проблема заключается в следующем: Я хочу интегрировать индикатор прогресса в функцию download_all. I

Выдает ошибку: IntegrityError at /o.../k... NOT NULL constraint failed: django_celery_results_taskresult.task_id

Как я могу решить эту проблему? functions.py

class myClass():

    def __init__(self, n_user, n_password, n_url, n_port, db_password, username):
        ...
        self.download_all(n_user, n_password, n_url, n_port, db_password)
        ...

    @shared_task(bind=True, name="my_add")
    def download_all(n_user, n_password, n_url, n_port, db_password)
     ...
     len_scans = len(scans)
     progress_recorder = ProgressRecorder(self)
     for s in scans:
         i = 0
         progress_recorder.set_progress(i + 1, len_scans)
         i += 1

views.py

def setup_wizard(request):
  ...
  functions.Zafiyet(setup.n_username, setup.n_password,
                                          setup.n_url, setup.n_port, setup.db_password,
                                          username=request.user.username)  

traceback

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