backoff from pulsar channels

Author: lsbardel

pq/tasks/consumer.py

@@ -3,14 +3,14 @@
 from multiprocessing import cpu_count
 
 from pulsar import ensure_future, CANCELLED_ERRORS
+from pulsar.apps.data.channels import backoff, RECONNECT_LAG
 
 from .executor import ExecutorMixin
 from .scheduler import SchedulerMixin
 from . import states
 from .task import Task, TaskNotAvailable
 from .models import RegistryMixin
 from .rpc import TasksRpc
-from ..pubsub import backoff, RECONNECT_LAG
 from ..consumer import ConsumerAPI