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; referencesisEnabledFor,copy,get,gethostname,maybe_iso8601,except,InvalidTaskError,maybe_make_awareRequest— class at line 67; referencescopy,get,gethostname,maybe_iso8601,except,InvalidTaskError,maybe_make_aware__init__— def at line 90; referencescopy,get,gethostname,maybe_iso8601,except,InvalidTaskError,maybe_make_awaredelivery_info— def at line 178; referencesgetmessage— def at line 182; referencesgetrequest_dict— def at line 186; referencesgetbody— def at line 190; referencesgetapp— def at line 194; referencesgetutc— def at line 198; referencesgetcontent_type— def at line 202; referencesgetcontent_encoding— def at line 206; referencesgettype— def at line 210; referencesgetroot_id— def at line 214; referencesgetparent_id— def at line 218; referencesgetargsrepr— def at line 222; referencesgetargs— def at line 226; referencesgetkwargs— def at line 230; referencesgetkwargsrepr— def at line 234; referencesgeton_ack— def at line 238; referencesgeton_reject— def at line 242; referencesgeton_reject— def at line 246; referencesgethostname— def at line 250; referencesgetignore_result— def at line 254; referencesgeteventer— def at line 258; referencesgeteventer— def at line 262; referencesgetconnection_errors— def at line 266; referencesgettask— def at line 270; referencesgeteta— def at line 274; referencesgetexpires— def at line 278; referencesgetexpires— def at line 282; referencesgettzlocal— def at line 286; referencesgetstore_errors— def at line 292; referencesgettask_id— def at line 297; referencesgettask_id— def at line 302; referencesgettask_name— def at line 306; referencesgettask_name— def at line 311; referencesgetreply_to— def at line 315; referencesgetreplaced_task_nesting— def at line 320; referencesgetgroups— def at line 324; referencesgetstamped_headers— def at line 328; referencesgetstamps— def at line 332; referencesgetcorrelation_id— def at line 337; referencesrevoked,TaskRevokedError,apply_async,maybe,acknowledge,updateexecute_using_pool— def at line 341; referencesrevoked,TaskRevokedError,apply_async,maybe,acknowledge,updateexecute— def at line 374; referencesrevoked,acknowledge,updatemaybe_expire— def at line 408; referencesnow,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_listterminate— def at line 416; referencessignum,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_listcancel— def at line 428; referencessignum,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; referencestask_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; referencestask_ready,send_event,mark_as_revoked,acknowledge,send_revoked,maybe_expire,isinstance,maybe_listrevoked— def at line 470; referencesmaybe_expire,isinstance,maybe_listsend_event— def at line 511; referencessendon_accepted— def at line 515; referencestime,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_clearon_timeout— def at line 529; referenceswarn,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,stron_success— def at line 596; referencesisinstance,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_rejecton_retry— def at line 613; referencesacknowledge,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_rejecton_failure— def at line 622; referencestask_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_rejectacknowledge— def at line 730; references_on_ack,_on_reject,send_eventreject— def at line 736; references_on_reject,send_eventinfo— def at line 742humaninfo— def at line 756; referencesformat,join,strip,type,get,update__str__— def at line 759; referencesjoin,humaninfo,strip,format,type,get,update__repr__— def at line 767; referencesformat,type,humaninfo,get,update_payload— def at line 775; referencesget,updatechord— def at line 779; referencesget,updateerrbacks— def at line 788; referencesget,updategroup— def at line 797; referencesget,update_context— def at line 803; referencesupdategroup_index— def at line 813; referencesgetcreate_request_cls— def at line 818; referencesrevoked,TaskRevokedError,apply_async,maybe,isinstance,on_failure,task_ready,acknowledge,send_eventRequest— class at line 830; referencesrevoked,TaskRevokedError,apply_async,maybe,isinstance,on_failure,task_ready,acknowledge,send_eventexecute_using_pool— def at line 832; referencesrevoked,TaskRevokedError,apply_async,maybeon_success— def at line 855; referencesisinstance,on_failure,task_ready,acknowledge,send_event
File-level call references
import— line 21hasattr— line 37get_logger— line 39isEnabledFor— line 50__optimize__— line 54copy— line 98get— line 115gethostname— line 124maybe_iso8601— line 138except— line 139InvalidTaskError— line 140maybe_make_aware— line 142update— line 165revoked— line 353TaskRevokedError— line 354apply_async— line 358maybe— line 371acknowledge— line 386trace_task— line 398reject— line 403now— line 411add— line 413signum— line 417terminate_job— line 419_announce_revoked— line 420_apply_result— line 424terminate— line 426_announce_cancelled— line 432task_ready— line 440send_event— line 441Retry— line 445mark_as_retry— line 446on_retry— line 450send_retry— line 455mark_as_revoked— line 461send_revoked— line 467maybe_expire— line 476isinstance— line 486maybe_list— line 488any— line 493info— line 504send— line 513time— line 519monotonic— line 519task_accepted— line 520debug— line 525warn— line 532error— line 539TimeLimitExceeded— line 540mark_as_failure— line 542ExceptionInfo— line 555on_failure— line 557task_has_custom— line 559after_return— line 560safe_repr— line 576get_pickled_exception— line 576traceback_clear— line 581safe_str— line 620str— line 645MemoryError— line 648and— line 706_on_ack— line 733_on_reject— line 738format— line 757join— line 761humaninfo— line 762strip— line 765type— line 770Context— line 810
Source: celery/worker/request.py