Home
last modified time | relevance | path

Searched refs:consume_from (Results 1 – 8 of 8) sorted by relevance

/dports/devel/py-celery/celery-4.4.7/celery/contrib/
H A Dmigrate.py215 return start_filter(app, conn, on_task, consume_from=queues, **kwargs)
253 consume_from=None, state=None, accept=None, **kwargs): argument
265 self.consume_from = [
267 for q in consume_from or list(self.queues)
297 queues=self.consume_from,
340 consume_from=None, state=None, accept=None, **kwargs): argument
352 consume_from=consume_from,
/dports/devel/py-celery/celery-4.4.7/celery/backends/
H A Dasynchronous.py178 self.result_consumer.consume_from(task_id)
241 def consume_from(self, task_id): member in BaseResultConsumer
H A Dredis.py166 def consume_from(self, task_id): member in ResultConsumer
343 self.result_consumer.consume_from(task_id)
H A Drpc.py79 def consume_from(self, task_id): member in ResultConsumer
/dports/devel/py-celery/celery-4.4.7/celery/app/
H A Damqp.py161 active = self.consume_from
212 def consume_from(self): member in Queues
303 queues=queues or list(self.queues.consume_from.values()),
/dports/devel/py-celery/celery-4.4.7/t/unit/bin/
H A Dtest_worker.py211 assert 'video' in app.amqp.queues.consume_from
213 assert 'celery' not in app.amqp.queues.consume_from
223 assert 'image' in app.amqp.queues.consume_from
/dports/devel/py-celery/celery-4.4.7/t/unit/backends/
H A Dtest_redis.py255 consumer.consume_from('some-task')
262 consumer.consume_from('some-task')
/dports/devel/py-celery/celery-4.4.7/docs/history/
H A Dchangelog-2.2.rst389 Queues are no longer removed, but rather `app.amqp.queues.consume_from()`