소스 검색

Don't explicitly delete the queue but rather leave that up to the broker and CELERY_AMQP_TASK_RESULT_EXPIRES. Closes #278

Ask Solem 14 년 전
부모
커밋
0d61ea5c26
1개의 변경된 파일0개의 추가작업 그리고 4개의 파일을 삭제
  1. 0 4
      celery/backends/amqp.py

+ 0 - 4
celery/backends/amqp.py

@@ -163,10 +163,6 @@ class AMQPBackend(BaseDictBackend):
             binding.declare()
             result = binding.get()
             if result:
-                try:
-                    binding.delete(if_unused=True, if_empty=True, nowait=True)
-                except conn.channel_errors:
-                    pass
                 payload = self._cache[task_id] = result.payload
                 return payload
             elif task_id in self._cache: