Explorar o código

No need to use inline imports for ALWAYS_EAGER

Ask Solem %!s(int64=15) %!d(string=hai) anos
pai
achega
a952bdf259
Modificáronse 2 ficheiros con 3 adicións e 5 borrados
  1. 2 3
      celery/execute.py
  2. 1 2
      celery/task/base.py

+ 2 - 3
celery/execute.py

@@ -5,8 +5,8 @@ from datetime import datetime, timedelta
 
 from billiard.utils.functional import curry
 
+from celery import conf
 from celery import signals
-from celery.conf import AMQP_CONNECTION_TIMEOUT
 from celery.utils import gen_unique_id, noop, fun_takes_kwargs
 from celery.result import AsyncResult, EagerResult
 from celery.registry import tasks
@@ -73,8 +73,7 @@ def apply_async(task, args=None, kwargs=None, countdown=None, eta=None,
     replaced by a local :func:`apply` call instead.
 
     """
-    from celery.conf import ALWAYS_EAGER
-    if ALWAYS_EAGER:
+    if conf.ALWAYS_EAGER:
         return apply(task, args, kwargs)
 
     for option_name in TASK_EXEC_OPTIONS:

+ 1 - 2
celery/task/base.py

@@ -517,8 +517,7 @@ class TaskSet(object):
             [True, True]
 
         """
-        from celery.conf import ALWAYS_EAGER
-        if ALWAYS_EAGER:
+        if conf.ALWAYS_EAGER:
             return self.apply()
 
         taskset_id = gen_unique_id()