Searched refs:apply_chord (Results 1 – 8 of 8) sorted by relevance
/dports/devel/py-celery/celery-4.4.7/t/unit/backends/ |
H A D | test_cache.py | 70 tb.apply_chord(result, None) 91 tb.apply_chord(result, None)
|
H A D | test_rpc.py | 44 self.b.apply_chord(self.app.GroupResult(), None)
|
H A D | test_base.py | 202 self.b.apply_chord(header_result, self.callback.s()) 213 self.b.apply_chord(header_result, body) 217 self.b.apply_chord(header_result, body.set(queue='test_queue')) 225 self.b.apply_chord(header_result, callback_queue.s()) 877 self.b.apply_chord(
|
H A D | test_redis.py | 548 self.b.apply_chord(header_result, None)
|
/dports/devel/py-celery/celery-4.4.7/celery/backends/ |
H A D | base.py | 616 def apply_chord(self, header_result, body, **kwargs): member in Backend 729 self.apply_chord = self._apply_chord_incr
|
H A D | redis.py | 404 def apply_chord(self, header_result, body, **kwargs): member in RedisBackend
|
/dports/devel/py-celery/celery-4.4.7/t/unit/tasks/ |
H A D | test_chord.py | 342 assert self.app.backend.apply_chord.call_count == 2
|
/dports/devel/py-celery/celery-4.4.7/celery/ |
H A D | canvas.py | 1423 app.backend.apply_chord(
|