Source symbols: t/unit/worker/test_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: 80
- Referenced calls: 113
Declared symbols
RequestCase— class at line 28; referencestask,KeyErrorsetup_method— def at line 30; referencestask,KeyErroradd— def at line 34; referencestask,KeyErrormytask— def at line 40; referencestask,KeyErrormytask_raising— def at line 46; referencesKeyErrorxRequest— def at line 51test_mro_lookup— class at line 64; referencesmro_lookuptest_order— def at line 66; referencesmro_lookupA— class at line 67; referencesmro_lookupB— class at line 70; referencesmro_lookupC— class at line 73; referencesmro_lookupD— class at line 76; referencesmro_lookupmro— def at line 79; referencesmro_lookupjail— def at line 92test_Retry— class at line 102; referencesException,Retry,patching,Mock,KeyError,uuid,jailtest_retry_semipredicate— def at line 104; referencesException,Retry,patching,Mock,KeyError,uuid,jailtest_trace_task— class at line 112; referencespatching,Mock,KeyError,uuid,jailtest_process_cleanup_fails— def at line 114; referencespatching,Mock,KeyError,uuid,jailtest_process_cleanup_BaseException— def at line 124; referencesMock,SystemExit,raises,jail,uuidtest_execute_jail_success— def at line 130; referencesjail,uuidtest_marked_as_started— def at line 134; referencesappend,Mock,uuid,jailstore_result— def at line 137; referencesappend,Mock,uuid,jailtest_execute_jail_failure— def at line 154; referencesjail,uuidtest_execute_task_ignore_result— def at line 161; referencestask,uuid,jailignores_result— def at line 163; referencesuuid,jailtest_execute_request_ignore_result— def at line 171; referencestask,uuid,jailignores_result— def at line 173; referencesuuid,jailtest_Request— class at line 185; referencestask_message_from_sig,copy,pop,Request,Mock,get_request,setget_request— def at line 187; referencestask_message_from_sig,copy,pop,Request,Mock,settest_shadow— def at line 211; referencesget_request,settest_args— def at line 215; referencesget_requesttest_kwargs— def at line 220test_info_function— def at line 225test_no_shadow_header— def at line 247; referencesget_requesttest_invalid_eta_raises_InvalidTaskError— def at line 252; referencesraises,get_request,settest_invalid_expires_raises_InvalidTaskError— def at line 256; referencesraises,get_request,settest_valid_expires_with_utc_makes_aware— def at line 260; referencespatch,get_request,set,assert_calledtest_maybe_expire_when_expires_is_None— def at line 266; referencesget_request,maybe_expiretest_on_retry_acks_if_late— def at line 270; referencesget_request,on_retry,Mock,assert_called_withtest_on_failure_Terminated— def at line 276; referencesTerminated,ExceptionInfo,get_request,on_failure,assert_called_withtest_on_failure_propagates_MemoryError— def at line 290; referencesMemoryError,ExceptionInfo,get_request,raises,on_failuretest_on_failure_Ignore_acknowledges— def at line 301; referencesIgnore,ExceptionInfo,get_request,on_failure,assert_called_withtest_on_failure_Reject_rejects— def at line 312; referencesReject,ExceptionInfo,get_request,Mock,on_failure,assert_called_withtest_on_failure_Reject_marks_as_failure— def at line 326; referencesReject,ExceptionInfo,get_request,Mock,connect,on_failure,disconnect,assert_called_once,getattr,isinstance,assert_called_with,anytest_on_failure_Reject_respects_send_failed_event— def at line 361; referencesReject,ExceptionInfo,get_request,Mock,on_failure,assert_called_once,anytest_on_failure_Reject_marks_as_failure_when_already_acked— def at line 379; referencesReject,ExceptionInfo,get_request,Mock,on_failure,assert_called_oncetest_on_failure_Reject_rejects_with_requeue— def at line 395; referencesReject,ExceptionInfo,get_request,Mock,on_failure,assert_called_with,assert_not_called,anytest_on_failure_WorkerLostError_rejects_with_requeue— def at line 416; referencesWorkerLostError,ExceptionInfo,get_request,Mock,on_failure,assert_called_with,assert_not_calledtest_on_failure_WorkerLostError_redelivered_None— def at line 434; referencesWorkerLostError,ExceptionInfo,get_request,Mock,on_failure,assert_called_with,assert_not_calledtest_on_failure_WorkerLostError_redelivered_True— def at line 452; referencesWorkerLostError,ExceptionInfo,get_request,Mock,assert_signal_called,on_failure,assert_called_once_withtest_on_failure_TimeLimitExceeded_acks— def at line 481; referencesTimeLimitExceeded,ExceptionInfo,get_request,Mock,on_failure,assert_called_with,assert_called_once_withtest_on_failure_TimeLimitExceeded_rejects_with_requeue— def at line 504; referencesTimeLimitExceeded,ExceptionInfo,get_request,Mock,on_failure,assert_called_with,assert_not_calledtest_tzlocal_is_cached— def at line 524; referencesget_requesttest_ignore_result_from_request_true— def at line 529; referencesget_request,settest_ignore_result_from_request_false— def at line 533; referencesget_request,settest_ignore_result_default_from_task_false— def at line 537; referencesget_requesttest_ignore_result_default_from_task_true— def at line 541; referencesget_requesttest_ignore_result_request_overrides_task_true— def at line 549; referencesget_request,settest_task_wrapper_repr— def at line 557; referencesrepr,xRequesttest_sets_store_errors— def at line 560; referencesxRequest,task_message_from_sig,copy,get_request,Mock,send_event,assert_called_with,assert_not_called,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_oncetest_store_errors_default— def at line 569; referencesxRequest,task_message_from_sig,copy,get_request,Mock,send_event,assert_called_with,assert_not_called,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_oncetest_store_errors_task_ignore_result— def at line 574; referencesxRequest,task_message_from_sig,copy,get_request,Mock,send_event,assert_called_with,assert_not_called,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_oncetest_store_errors_request_overrides_task_ignore_result— def at line 579; referencestask_message_from_sig,copy,get_request,xRequest,Mock,send_event,assert_called_with,assert_not_called,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_oncetest_ignore_result_from_request_none— def at line 590; referencestask_message_from_sig,copy,get_request,xRequest,Mock,send_event,assert_called_with,assert_not_called,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_oncetest_send_event— def at line 598; referencesxRequest,Mock,send_event,assert_called_with,assert_not_called,get_request,Retry,KeyError,ExceptionInfo,on_failure,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_once,set,nowtest_send_events__disabled_at_task_level— def at line 604; referencesxRequest,Mock,send_event,assert_not_called,get_request,Retry,KeyError,ExceptionInfo,on_failure,assert_called_with,safe_repr,safe_str,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_called_once,set,nowtest_on_retry— def at line 611; referencesget_request,Mock,Retry,KeyError,ExceptionInfo,on_failure,assert_called_with,safe_repr,safe_str,xRequest,assert_signal_called,monotonic,terminate,_apply_result,cancel,assert_not_called,assert_called_once,set,now,timedeltatest_compat_properties— def at line 633; referencesxRequest,Mock,get_request,assert_signal_called,monotonic,terminate,_apply_result,assert_called_with,cancel,assert_not_called,assert_called_once,set,now,timedelta,revoked,set_current,get_status,add,parametrizetest_terminate__pool_ref— def at line 642; referencesMock,get_request,assert_signal_called,monotonic,terminate,_apply_result,assert_called_with,cancel,assert_not_called,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_terminate__task_started— def at line 659; referencesMock,get_request,assert_signal_called,monotonic,terminate,assert_called_with,cancel,_apply_result,assert_not_called,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_cancel__pool_ref— def at line 671; referencesMock,get_request,assert_signal_called,monotonic,cancel,_apply_result,assert_called_with,terminate,assert_not_called,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_terminate__task_reserved— def at line 688; referencesMock,get_request,terminate,assert_not_called,assert_signal_called,monotonic,cancel,_apply_result,assert_called_with,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_cancel__task_started— def at line 697; referencesMock,get_request,assert_signal_called,monotonic,cancel,_apply_result,assert_called_with,assert_not_called,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_cancel__task_reserved— def at line 710; referencesMock,get_request,cancel,assert_not_called,assert_signal_called,monotonic,assert_called_with,assert_called_once,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_cancel__emit_retry_true— def at line 718; referencesMock,get_request,assert_signal_called,monotonic,cancel,assert_called_with,assert_called_once,assert_not_called,set,now,timedelta,revoked,set_current,get_status,xRequest,add,parametrizetest_cancel__emit_retry_false— def at line 736; referencesMock,get_request,monotonic,cancel,assert_called_with,assert_not_called,set,now,timedelta,assert_signal_called,revoked,set_current,get_status,xRequest,add,parametrizetest_revoked_expires_expired— def at line 751; referencesget_request,set,now,timedelta,assert_signal_called,revoked,set_current,get_status,xRequest,add,parametrizetest_revoked_expires_not_expired— def at line 763; referencesxRequest,now,timedelta,revoked,get_status,assert_signal_called,add,parametrizetest_revoked_expires_ignore_result— def at line 771; referencesxRequest,now,timedelta,revoked,get_status,assert_signal_called,add,parametrizetest_already_revoked— def at line 780; referencesxRequest,revoked,assert_signal_called,add,parametrize
File-level call references
import— line 15task— line 33KeyError— line 47Mock— line 55TaskMessage— line 57Request— line 60mro_lookup— line 83update— line 94trace_task— line 97Exception— line 106Retry— line 108patching— line 115uuid— line 118jail— line 119assert_called— line 121SystemExit— line 126raises— line 127append— line 139isinstance— line 158AsyncResult— line 169ready— line 169task_message_from_sig— line 193copy— line 195pop— line 198get_request— line 212set— line 213range— line 229str— line 230join— line 230choice— line 231info— line 233get— line 233list— line 241patch— line 261maybe_expire— line 268on_retry— line 273assert_called_with— line 274Terminated— line 279ExceptionInfo— line 281on_failure— line 284MemoryError— line 293Ignore— line 304Reject— line 315connect— line 338disconnect— line 342assert_called_once— line 343getattr— line 346any— line 356assert_not_called— line 410WorkerLostError— line 418assert_signal_called— line 464assert_called_once_with— line 476TimeLimitExceeded— line 483repr— line 558xRequest— line 558send_event— line 601safe_repr— line 622safe_str— line 623monotonic— line 650terminate— line 652_apply_result— line 653cancel— line 681now— line 753timedelta— line 753revoked— line 758set_current— line 760get_status— line 761add— line 790parametrize— line 795clear— line 806keys— line 809execute— line 825execute_using_pool— line 841on_accepted— line 845getpid— line 845time— line 874on_success— line 879get_ei— line 932on_timeout— line 1202after_return_mock— line 1367TaskWithAfterReturn— line 1369register— line 1370original_mark— line 1396object— line 1398setup_worker_optimizations— line 1409len— line 1413build_tracer— line 1415fast_trace_task— line 1419reset_worker_optimizations— line 1427delattr— line 1429trace_task_ret— line 1430warns— line 1473push_request— line 1479ValueError— line 1481TraceInfo— line 1486handle_retry— line 1487pop_request— line 1496handle_failure— line 1507get_task_meta— line 1554BaseDictBackend— line 1565type— line 1659_test_on_failure— line 1666from_utf8— line 1673reject— line 1688reset_mock— line 1693super— line 1714setup_method— line 1714create_request_cls— line 1717zRequest— line 1731exc— line 1738apply_async— line 1814weakref_ref— line 1815hybrid_to_proto2— line 1863
Source: t/unit/worker/test_request.py