|
@@ -13,7 +13,7 @@ import sys
|
|
import threading
|
|
import threading
|
|
import traceback
|
|
import traceback
|
|
|
|
|
|
-from kombu.syn import detect_environment
|
|
|
|
|
|
+from kombu.syn import _detect_environment
|
|
|
|
|
|
from celery.local import Proxy
|
|
from celery.local import Proxy
|
|
|
|
|
|
@@ -318,7 +318,7 @@ class _FastLocalStack(threading.local):
|
|
except (AttributeError, IndexError):
|
|
except (AttributeError, IndexError):
|
|
return None
|
|
return None
|
|
|
|
|
|
-if detect_environment() == 'default' and not USE_PURE_LOCALS:
|
|
|
|
|
|
+if _detect_environment() == 'default' and not USE_PURE_LOCALS:
|
|
LocalStack = _FastLocalStack
|
|
LocalStack = _FastLocalStack
|
|
else:
|
|
else:
|
|
# - See #706
|
|
# - See #706
|