Source symbols: celery/worker/request.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: 72
• Referenced calls: 69

Declared symbols

• __optimize__ — def at line 46; references isEnabledFor, copy, get, gethostname, maybe_iso8601, except, InvalidTaskError, maybe_make_aware
• Request — class at line 67; references copy, get, gethostname, maybe_iso8601, except, InvalidTaskError, maybe_make_aware
• __init__ — def at line 90; references copy, get, gethostname, maybe_iso8601, except, InvalidTaskError, maybe_make_aware
• delivery_info — def at line 178; references get
• message — def at line 182; references get
• request_dict — def at line 186; references get
• body — def at line 190; references get
• app — def at line 194; references get
• utc — def at line 198; references get
• content_type — def at line 202; references get
• content_encoding — def at line 206; references get
• type — def at line 210; references get
• root_id — def at line 214; references get
• parent_id — def at line 218; references get
• argsrepr — def at line 222; references get
• args — def at line 226; references get
• kwargs — def at line 230; references get
• kwargsrepr — def at line 234; references get
• on_ack — def at line 238; references get
• on_reject — def at line 242; references get
• on_reject — def at line 246; references get
• hostname — def at line 250; references get
• ignore_result — def at line 254; references get
• eventer — def at line 258; references get
• eventer — def at line 262; references get
• connection_errors — def at line 266; references get
• task — def at line 270; references get
• eta — def at line 274; references get
• expires — def at line 278; references get
• expires — def at line 282; references get
• tzlocal — def at line 286; references get
• store_errors — def at line 292; references get
• task_id — def at line 297; references get
• task_id — def at line 302; references get
• task_name — def at line 306; references get
• task_name — def at line 311; references get
• reply_to — def at line 315; references get
• replaced_task_nesting — def at line 320; references get
• groups — def at line 324; references get
• stamped_headers — def at line 328; references get
• stamps — def at line 332; references get
• correlation_id — def at line 337; references revoked, TaskRevokedError, apply_async, maybe, acknowledge, update
• execute_using_pool — def at line 341; references revoked, TaskRevokedError, apply_async, maybe, acknowledge, update
• execute — def at line 374; references revoked, acknowledge, update
• maybe_expire — def at line 408; references now, add, signum, terminate_job, _announce_revoked, _apply_result, terminate, _announce_cancelled, task_ready, send_event, Retry, mark_as_retry, on_retry, send_retry, mark_as_revoked, acknowledge, send_revoked, isinstance, maybe_list
• terminate — def at line 416; references signum, terminate_job, _announce_revoked, _apply_result, _announce_cancelled, task_ready, send_event, Retry, mark_as_retry, on_retry, send_retry, mark_as_revoked, acknowledge, send_revoked, maybe_expire, isinstance, maybe_list
• cancel — def at line 428; references signum, terminate_job, _announce_cancelled, _apply_result, terminate, task_ready, send_event, Retry, mark_as_retry, on_retry, send_retry, mark_as_revoked, acknowledge, send_revoked, maybe_expire, isinstance, maybe_list
• _announce_cancelled — def at line 439; references task_ready, send_event, Retry, mark_as_retry, on_retry, send_retry, mark_as_revoked, acknowledge, send_revoked, maybe_expire, isinstance, maybe_list
• _announce_revoked — def at line 457; references task_ready, send_event, mark_as_revoked, acknowledge, send_revoked, maybe_expire, isinstance, maybe_list
• revoked — def at line 470; references maybe_expire, isinstance, maybe_list
• send_event — def at line 511; references send
• on_accepted — def at line 515; references time, monotonic, task_accepted, acknowledge, send_event, debug, terminate, warn, task_ready, error, TimeLimitExceeded, mark_as_failure, ExceptionInfo, on_failure, task_has_custom, after_return, send, safe_repr, get_pickled_exception, traceback_clear
• on_timeout — def at line 529; references warn, task_ready, error, TimeLimitExceeded, mark_as_failure, ExceptionInfo, on_failure, task_has_custom, after_return, send, send_event, safe_repr, get_pickled_exception, traceback_clear, acknowledge, reject, isinstance, safe_str, _announce_revoked, str
• on_success — def at line 596; references isinstance, on_failure, task_ready, acknowledge, send_event, safe_repr, safe_str, _announce_revoked, str, MemoryError, mark_as_failure, send, get_pickled_exception, reject, on_retry, and, error, _on_ack, _on_reject
• on_retry — def at line 613; references acknowledge, send_event, safe_repr, safe_str, task_ready, isinstance, _announce_revoked, str, MemoryError, mark_as_failure, send, get_pickled_exception, reject, and, error, _on_ack, _on_reject
• on_failure — def at line 622; references task_ready, isinstance, _announce_revoked, str, MemoryError, mark_as_failure, send, send_event, safe_repr, get_pickled_exception, reject, acknowledge, on_retry, and, error, _on_ack, _on_reject
• acknowledge — def at line 730; references _on_ack, _on_reject, send_event
• reject — def at line 736; references _on_reject, send_event
• info — def at line 742
• humaninfo — def at line 756; references format, join, strip, type, get, update
• __str__ — def at line 759; references join, humaninfo, strip, format, type, get, update
• __repr__ — def at line 767; references format, type, humaninfo, get, update
• _payload — def at line 775; references get, update
• chord — def at line 779; references get, update
• errbacks — def at line 788; references get, update
• group — def at line 797; references get, update
• _context — def at line 803; references update
• group_index — def at line 813; references get
• create_request_cls — def at line 818; references revoked, TaskRevokedError, apply_async, maybe, isinstance, on_failure, task_ready, acknowledge, send_event
• Request — class at line 830; references revoked, TaskRevokedError, apply_async, maybe, isinstance, on_failure, task_ready, acknowledge, send_event
• execute_using_pool — def at line 832; references revoked, TaskRevokedError, apply_async, maybe
• on_success — def at line 855; references isinstance, on_failure, task_ready, acknowledge, send_event

File-level call references

• import — line 21
• hasattr — line 37
• get_logger — line 39
• isEnabledFor — line 50
• __optimize__ — line 54
• copy — line 98
• get — line 115
• gethostname — line 124
• maybe_iso8601 — line 138
• except — line 139
• InvalidTaskError — line 140
• maybe_make_aware — line 142
• update — line 165
• revoked — line 353
• TaskRevokedError — line 354
• apply_async — line 358
• maybe — line 371
• acknowledge — line 386
• trace_task — line 398
• reject — line 403
• now — line 411
• add — line 413
• signum — line 417
• terminate_job — line 419
• _announce_revoked — line 420
• _apply_result — line 424
• terminate — line 426
• _announce_cancelled — line 432
• task_ready — line 440
• send_event — line 441
• Retry — line 445
• mark_as_retry — line 446
• on_retry — line 450
• send_retry — line 455
• mark_as_revoked — line 461
• send_revoked — line 467
• maybe_expire — line 476
• isinstance — line 486
• maybe_list — line 488
• any — line 493
• info — line 504
• send — line 513
• time — line 519
• monotonic — line 519
• task_accepted — line 520
• debug — line 525
• warn — line 532
• error — line 539
• TimeLimitExceeded — line 540
• mark_as_failure — line 542
• ExceptionInfo — line 555
• on_failure — line 557
• task_has_custom — line 559
• after_return — line 560
• safe_repr — line 576
• get_pickled_exception — line 576
• traceback_clear — line 581
• safe_str — line 620
• str — line 645
• MemoryError — line 648
• and — line 706
• _on_ack — line 733
• _on_reject — line 738
• format — line 757
• join — line 761
• humaninfo — line 762
• strip — line 765
• type — line 770
• Context — line 810

Source: celery/worker/request.py