소스 검색

AMQP Result Backend: Queue must be declared before polling result. Thanks to bmbouter

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

+ 1 - 0
celery/backends/amqp.py

@@ -148,6 +148,7 @@ class AMQPBackend(BaseDictBackend):
         channel = conn.channel()
         try:
             binding = self._create_binding(task_id)(channel)
+            binding.declare()
             result = binding.get()
             if result:
                 try: