Function allow_join_result

celery/result.py:42–48 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

40
41	@contextmanager
42	def allow_join_result():
43	reset_value = task_join_will_block()
44	_set_task_join_will_block(False)
45	try:
46	yield
47	finally:
48	_set_task_join_will_block(reset_value)
49
50
51	@contextmanager

test_chord_unlock_stress_routing_to_quorum_queueFunction · 0.90

unlock_graphFunction · 0.90

apply_asyncMethod · 0.90

start_workerFunction · 0.90

on_chord_part_returnMethod · 0.90

unlock_chordFunction · 0.90

task_join_will_blockFunction · 0.85

_set_task_join_will_blockFunction · 0.85

test_chord_unlock_stress_routing_to_quorum_queueFunction · 0.72