Ask Solem 11 years ago
parent
commit
8fdc201255
2 changed files with 3 additions and 3 deletions
  1. 2 2
      celery/loaders/base.py
  2. 1 1
      celery/result.py

+ 2 - 2
celery/loaders/base.py

@@ -9,7 +9,7 @@
 from __future__ import absolute_import
 
 import anyjson
-import imp
+import imp as _imp
 import importlib
 import os
 import re
@@ -284,7 +284,7 @@ def find_related_module(package, related_name):
         return
 
     try:
-        imp.find_module(related_name, pkg_path)
+        _imp.find_module(related_name, pkg_path)
     except ImportError:
         return
 

+ 1 - 1
celery/result.py

@@ -415,7 +415,7 @@ class ResultSet(ResultBase):
             result.forget()
 
     def revoke(self, connection=None, terminate=False, signal=None,
-            wait=False, timeout=None):
+               wait=False, timeout=None):
         """Send revoke signal to all workers for all tasks in the set.
 
         :keyword terminate: Also terminate the process currently working