kombu.syn moved to kombu.compat

celery/backends/async.py

@@ -8,7 +8,7 @@ from collections import deque
 from time import sleep
 from weakref import WeakKeyDictionary
 
-from kombu.syn import detect_environment
+from kombu.utils.compat import detect_environment
 from kombu.utils.objects import cached_property
 
 from celery import states

celery/worker/__init__.py

@@ -24,7 +24,7 @@ except ImportError:  # pragma: no cover
 
 from billiard import cpu_count
 from billiard.util import Finalize
-from kombu.syn import detect_environment
+from kombu.utils.compat import detect_environment
 
 from celery import bootsteps
 from celery.bootsteps import RUN, TERMINATE

celery/worker/consumer/consumer.py

@@ -17,7 +17,7 @@ from time import sleep
 from billiard.common import restart_state
 from billiard.exceptions import RestartFreqExceeded
 from kombu.async.semaphore import DummyLock
-from kombu.syn import _detect_environment
+from kombu.utils.compat import _detect_environment
 from kombu.utils.encoding import safe_repr, bytes_t
 from kombu.utils.limits import TokenBucket
 from vine import ppartial, promise