Вызов Celery Inspect из Django терпит неудачу на каждом 2 запросе с ошибкой "недостаточно значений для распаковки (ожидалось 2, получено 1)"

Я вызываю следующий код из представления django (взято из https://docs.celeryq.dev/en/latest/userguide/workers.html#inspecting-workers):

inspect_report = celery_app.control.inspect()
tasks_active = inspect_report.active()

В первый раз все работает правильно, но когда я обновляю страницу, появляется ValueError: not enough values to unpack (expected 2, got 1)

Stacktrace:

 File "/venv_path/python3.9/site-packages/asgiref/sync.py", line 458, in thread_handler
    raise exc_info[1]
  File "/venv_path/python3.9/site-packages/django/core/handlers/exception.py", line 38, in inner
    response = await get_response(request)
  File "/venv_path/python3.9/site-packages/django/core/handlers/base.py", line 233, in _get_response_async
    response = await wrapped_callback(request, *callback_args, **callback_kwargs)
  File "/venv_path/python3.9/site-packages/asgiref/sync.py", line 423, in __call__
    ret = await asyncio.wait_for(future, timeout=None)
  File "/home/benjamin/.pyenv/versions/3.9.6/lib/python3.9/asyncio/tasks.py", line 442, in wait_for
    return await fut
  File "/venv_path/python3.9/site-packages/asgiref/current_thread_executor.py", line 22, in run
    result = self.fn(*self.args, **self.kwargs)
  File "/venv_path/python3.9/site-packages/asgiref/sync.py", line 462, in thread_handler
    return func(*args, **kwargs)
  File "/venv_path/python3.9/site-packages/django/views/decorators/cache.py", line 44, in _wrapped_view_func
    response = view_func(request, *args, **kwargs)
  File "/venv_path/python3.9/site-packages/django/contrib/auth/decorators.py", line 21, in _wrapped_view
    return view_func(request, *args, **kwargs)
  File "/home/benjamin/project/administration/views.py", line 357, in dashboard
    tasks_active = inspect_report.active()
  File "/venv_path/python3.9/site-packages/celery/app/control.py", line 149, in active
    return self._request('active', safe=safe)
  File "/venv_path/python3.9/site-packages/celery/app/control.py", line 106, in _request
    return self._prepare(self.app.control.broadcast(
  File "/venv_path/python3.9/site-packages/celery/app/control.py", line 741, in broadcast
    return self.mailbox(conn)._broadcast(
  File "/venv_path/python3.9/site-packages/kombu/pidbox.py", line 344, in _broadcast
    return self._collect(reply_ticket, limit=limit,
  File "/venv_path/python3.9/site-packages/kombu/pidbox.py", line 386, in _collect
    self.connection.drain_events(timeout=timeout)
  File "/venv_path/python3.9/site-packages/kombu/connection.py", line 317, in drain_events
    return self.transport.drain_events(self.connection, **kwargs)
  File "/venv_path/python3.9/site-packages/kombu/transport/virtual/base.py", line 969, in drain_events
    get(self._deliver, timeout=timeout)
  File "/venv_path/python3.9/site-packages/kombu/transport/redis.py", line 526, in get
    ret = self.handle_event(fileno, event)
  File "/venv_path/python3.9/site-packages/kombu/transport/redis.py", line 508, in handle_event
    return self.on_readable(fileno), self
  File "/venv_path/python3.9/site-packages/kombu/transport/redis.py", line 504, in on_readable
    chan.handlers[type]()
  File "/venv_path/python3.9/site-packages/kombu/transport/redis.py", line 905, in _brpop_read
    dest, item = dest__item
ValueError: not enough values to unpack (expected 2, got 1)

3-я страница вызывается нормально, 4-я дает ту же ошибку и т.д.

Почему он не работает каждые 2 запроса?

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