Browse Source

backend.wait_for() sleeps for 0.5s again, temporarily had it at 0.05 and
managed to commit the value.

Ask Solem 16 years ago
parent
commit
06b9165a29
1 changed files with 1 additions and 1 deletions
  1. 1 1
      celery/backends/base.py

+ 1 - 1
celery/backends/base.py

@@ -175,7 +175,7 @@ class BaseBackend(object):
                 return self.get_result(task_id)
                 return self.get_result(task_id)
             elif status == "FAILURE":
             elif status == "FAILURE":
                 raise self.get_result(task_id)
                 raise self.get_result(task_id)
-            time.sleep(0.05) # avoid hammering the CPU checking status.
+            time.sleep(0.5) # avoid hammering the CPU checking status.
             timeout_timer.tick()
             timeout_timer.tick()
 
 
     def process_cleanup(self):
     def process_cleanup(self):