Task modules are now imported from the current directory

celery/loaders/base.py

@@ -1,3 +1,6 @@
+import os
+import sys
+
 from importlib import import_module
 
 BUILTIN_MODULES = ["celery.task"]
@@ -37,7 +40,7 @@ class BaseLoader(object):
         pass
 
     def import_task_module(self, module):
-        return self.import_module(module)
+        return self.import_from_cwd(module)
 
     def import_module(self, module):
         return import_module(module)
@@ -52,6 +55,25 @@ class BaseLoader(object):
             self.worker_initialized = True
             self.on_worker_init()
 
+    def import_from_cwd(self, module, imp=import_module):
+        """Import module, but make sure it finds modules
+        located in the current directory.
+
+        Modules located in the current directory has
+        precedence over modules located in ``sys.path``.
+        """
+        cwd = os.getcwd()
+        if cwd in sys.path:
+            return imp(module)
+        sys.path.insert(0, cwd)
+        try:
+            return imp(module)
+        finally:
+            try:
+                sys.path.remove(cwd)
+            except ValueError:          # pragma: no cover
+                pass
+
     @property
     def conf(self):
         """Loader configuration."""

celery/loaders/default.py

@@ -1,5 +1,4 @@
 import os
-import sys
 import warnings
 from importlib import import_module
 
@@ -47,25 +46,6 @@ class Loader(BaseLoader):
 
         return settings
 
-    def import_from_cwd(self, module, imp=import_module):
-        """Import module, but make sure it finds modules
-        located in the current directory.
-
-        Modules located in the current directory has
-        precedence over modules located in ``sys.path``.
-        """
-        cwd = os.getcwd()
-        if cwd in sys.path:
-            return imp(module)
-        sys.path.insert(0, cwd)
-        try:
-            return imp(module)
-        finally:
-            try:
-                sys.path.remove(cwd)
-            except ValueError:          # pragma: no cover
-                pass
-
     def read_configuration(self):
         """Read configuration from ``celeryconfig.py`` and configure
         celery and Django so it can be used by regular Python."""