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; references Event, ready, send, wait
• __init__ — def at line 41; references Event, ready, send, wait
• is_set — def at line 45; references ready, send, wait
• set — def at line 48; references send, wait
• wait — def at line 51
• register_drainer — def at line 58
• _inner — def at line 60; references register_drainer
• Drainer — class at line 67; references monotonic, timeout, wait_for, warning, sleep, on_interval, wait, Event
• __init__ — def at line 70
• start — def at line 73
• stop — def at line 76
• drain_events_until — def at line 79; references monotonic, timeout, wait_for, warning, sleep, on_interval
• wait_for — def at line 108; references wait
• _event — def at line 111; references Event
• greenletDrainer — class at line 115; references set, _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; references set, _event
• __init__ — def at line 125; references super, _event
• run — def at line 133; references set, is_set, drain_events, _send_drain_complete_event, warning, sleep, error
• start — def at line 164; references _ensure_not_shut_down, is_set, spawn, wait
• stop — def at line 171; references set, wait
• wait_for — def at line 175; references start, wait, _ensure_not_shut_down
• _ensure_not_shut_down — def at line 182; references is_set, Exception, register_drainer
• eventletDrainer — class at line 199; references spawn, sleep, EventletAdaptedEvent, register_drainer
• spawn — def at line 201; references sleep
• _event — def at line 207; references EventletAdaptedEvent, register_drainer
• geventDrainer — class at line 212; references spawn, sleep, Event
• spawn — def at line 214; references sleep
• _event — def at line 220; references Event
• AsyncBackendMixin — 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 228
• iter_native — def at line 231; references _ensure_not_eager, StopIteration, deque, hasattr, append, _collect_into, _wait_for_pending, popleft
• add_pending_result — def at line 260; references start, _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; references consume_from
• add_pending_results — def at line 278; references start, add_pending_result
• remove_pending_result — def at line 283; references _remove_pending_result, on_result_fulfilled
• _remove_pending_result — def at line 288; references pop
• on_result_fulfilled — def at line 292; references cancel_for
• wait_for_pending — def at line 295; references _ensure_not_eager, _wait_for_pending, maybe_throw
• _wait_for_pending — def at line 302
• is_async — def at line 312
• BaseResultConsumer — class at line 316; references WeakKeyDictionary, 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; references WeakKeyDictionary, detect_environment
• start — def at line 335; references NotImplementedError
• reconnect_on_error — def at line 339; references _reconnect, critical, RuntimeError
• _reconnect — def at line 363
• stop — def at line 372
• drain_events — def at line 375; references NotImplementedError
• consume_from — def at line 378; references NotImplementedError
• cancel_for — def at line 381; references NotImplementedError
• _after_fork — def at line 384; references clear, WeakKeyDictionary, on_after_fork
• on_after_fork — def at line 390
• drain_events_until — def at line 393
• _wait_for_pending — def at line 397; references on_wait_for_pending, drain_events_until, sleep, TimeoutError
• on_wait_for_pending — def at line 413
• on_out_of_band_result — def at line 416; references on_state_change
• _get_pending_result — def at line 419; references KeyError
• on_state_change — def at line 427; references on_message, _get_pending_result, put, _maybe_set_cache, pop, append, sleep

File-level call references

• get_logger — line 27
• Event — line 43
• ready — line 46
• send — line 49
• wait — line 52
• register_drainer — line 66
• monotonic — line 81
• timeout — line 86
• wait_for — line 88
• warning — line 96
• sleep — line 101
• on_interval — line 104
• set — line 122
• _event — line 123
• super — line 126
• __init__ — line 126
• is_set — line 137
• drain_events — line 139
• _send_drain_complete_event — line 140
• error — line 162
• _ensure_not_shut_down — line 165
• spawn — line 168
• start — line 176
• Exception — line 195
• EventletAdaptedEvent — line 208
• _ensure_not_eager — line 232
• StopIteration — line 236
• deque — line 240
• hasattr — line 242
• append — line 243
• _collect_into — line 247
• _wait_for_pending — line 249
• popleft — line 251
• _maybe_resolve_from_buffer — line 264
• _add_pending_result — line 266
• _maybe_set_cache — line 270
• take — line 270
• consume_from — line 276
• add_pending_result — line 280
• _remove_pending_result — line 284
• on_result_fulfilled — line 285
• pop — line 290
• cancel_for — line 293
• maybe_throw — line 300
• WeakKeyDictionary — line 332
• detect_environment — line 333
• NotImplementedError — line 336
• _reconnect — line 358
• critical — line 360
• RuntimeError — line 361
• clear — line 385
• on_after_fork — line 388
• drain_events_until — line 394
• on_wait_for_pending — line 400
• TimeoutError — line 409
• on_state_change — line 417
• KeyError — line 425
• on_message — line 429
• _get_pending_result — line 433
• put — line 437

Source: celery/backends/asynchronous.py