Source symbols: celery/backends/asynchronous.py
Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.
- Revision: main@97ed017c09de03612a7d9617ff4c038c00bf916b · 2026-07-19T16:04:39Z
- Declarations: 58
- Referenced calls: 60
Declared symbols
EventletAdaptedEvent— class at line 35; referencesEvent,ready,send,wait__init__— def at line 41; referencesEvent,ready,send,waitis_set— def at line 45; referencesready,send,waitset— def at line 48; referencessend,waitwait— def at line 51register_drainer— def at line 58_inner— def at line 60; referencesregister_drainerDrainer— class at line 67; referencesmonotonic,timeout,wait_for,warning,sleep,on_interval,wait,Event__init__— def at line 70start— def at line 73stop— def at line 76drain_events_until— def at line 79; referencesmonotonic,timeout,wait_for,warning,sleep,on_intervalwait_for— def at line 108; referenceswait_event— def at line 111; referencesEventgreenletDrainer— class at line 115; referencesset,_event,super,__init__,is_set,drain_events,_send_drain_complete_event,warning,sleep,error,_ensure_not_shut_down,spawn,wait,start,Exception,register_drainer_send_drain_complete_event— def at line 121; referencesset,_event__init__— def at line 125; referencessuper,_eventrun— def at line 133; referencesset,is_set,drain_events,_send_drain_complete_event,warning,sleep,errorstart— def at line 164; references_ensure_not_shut_down,is_set,spawn,waitstop— def at line 171; referencesset,waitwait_for— def at line 175; referencesstart,wait,_ensure_not_shut_down_ensure_not_shut_down— def at line 182; referencesis_set,Exception,register_drainereventletDrainer— class at line 199; referencesspawn,sleep,EventletAdaptedEvent,register_drainerspawn— def at line 201; referencessleep_event— def at line 207; referencesEventletAdaptedEvent,register_drainergeventDrainer— class at line 212; referencesspawn,sleep,Eventspawn— def at line 214; referencessleep_event— def at line 220; referencesEventAsyncBackendMixin— class at line 225; references_ensure_not_eager,StopIteration,deque,hasattr,append,_collect_into,_wait_for_pending,popleft,start,_maybe_resolve_from_buffer,_add_pending_result,_maybe_set_cache,take,consume_from,add_pending_result,_remove_pending_result,on_result_fulfilled,pop,cancel_for,maybe_throw_collect_into— def at line 228iter_native— def at line 231; references_ensure_not_eager,StopIteration,deque,hasattr,append,_collect_into,_wait_for_pending,popleftadd_pending_result— def at line 260; referencesstart,_maybe_resolve_from_buffer,_add_pending_result_maybe_resolve_from_buffer— def at line 269; references_maybe_set_cache,take_add_pending_result— def at line 272; referencesconsume_fromadd_pending_results— def at line 278; referencesstart,add_pending_resultremove_pending_result— def at line 283; references_remove_pending_result,on_result_fulfilled_remove_pending_result— def at line 288; referencespopon_result_fulfilled— def at line 292; referencescancel_forwait_for_pending— def at line 295; references_ensure_not_eager,_wait_for_pending,maybe_throw_wait_for_pending— def at line 302is_async— def at line 312BaseResultConsumer— class at line 316; referencesWeakKeyDictionary,detect_environment,NotImplementedError,_reconnect,critical,RuntimeError,clear,on_after_fork,drain_events_until,on_wait_for_pending,sleep,TimeoutError,on_state_change,KeyError,on_message,_get_pending_result,put,_maybe_set_cache,pop,append__init__— def at line 324; referencesWeakKeyDictionary,detect_environmentstart— def at line 335; referencesNotImplementedErrorreconnect_on_error— def at line 339; references_reconnect,critical,RuntimeError_reconnect— def at line 363stop— def at line 372drain_events— def at line 375; referencesNotImplementedErrorconsume_from— def at line 378; referencesNotImplementedErrorcancel_for— def at line 381; referencesNotImplementedError_after_fork— def at line 384; referencesclear,WeakKeyDictionary,on_after_forkon_after_fork— def at line 390drain_events_until— def at line 393_wait_for_pending— def at line 397; referenceson_wait_for_pending,drain_events_until,sleep,TimeoutErroron_wait_for_pending— def at line 413on_out_of_band_result— def at line 416; referenceson_state_change_get_pending_result— def at line 419; referencesKeyErroron_state_change— def at line 427; referenceson_message,_get_pending_result,put,_maybe_set_cache,pop,append,sleep
File-level call references
get_logger— line 27Event— line 43ready— line 46send— line 49wait— line 52register_drainer— line 66monotonic— line 81timeout— line 86wait_for— line 88warning— line 96sleep— line 101on_interval— line 104set— line 122_event— line 123super— line 126__init__— line 126is_set— line 137drain_events— line 139_send_drain_complete_event— line 140error— line 162_ensure_not_shut_down— line 165spawn— line 168start— line 176Exception— line 195EventletAdaptedEvent— line 208_ensure_not_eager— line 232StopIteration— line 236deque— line 240hasattr— line 242append— line 243_collect_into— line 247_wait_for_pending— line 249popleft— line 251_maybe_resolve_from_buffer— line 264_add_pending_result— line 266_maybe_set_cache— line 270take— line 270consume_from— line 276add_pending_result— line 280_remove_pending_result— line 284on_result_fulfilled— line 285pop— line 290cancel_for— line 293maybe_throw— line 300WeakKeyDictionary— line 332detect_environment— line 333NotImplementedError— line 336_reconnect— line 358critical— line 360RuntimeError— line 361clear— line 385on_after_fork— line 388drain_events_until— line 394on_wait_for_pending— line 400TimeoutError— line 409on_state_change— line 417KeyError— line 425on_message— line 429_get_pending_result— line 433put— line 437
Source: celery/backends/asynchronous.py