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; references task, KeyError
• setup_method — def at line 30; references task, KeyError
• add — def at line 34; references task, KeyError
• mytask — def at line 40; references task, KeyError
• mytask_raising — def at line 46; references KeyError
• xRequest — def at line 51
• test_mro_lookup — class at line 64; references mro_lookup
• test_order — def at line 66; references mro_lookup
• A — class at line 67; references mro_lookup
• B — class at line 70; references mro_lookup
• C — class at line 73; references mro_lookup
• D — class at line 76; references mro_lookup
• mro — def at line 79; references mro_lookup
• jail — def at line 92
• test_Retry — class at line 102; references Exception, Retry, patching, Mock, KeyError, uuid, jail
• test_retry_semipredicate — def at line 104; references Exception, Retry, patching, Mock, KeyError, uuid, jail
• test_trace_task — class at line 112; references patching, Mock, KeyError, uuid, jail
• test_process_cleanup_fails — def at line 114; references patching, Mock, KeyError, uuid, jail
• test_process_cleanup_BaseException — def at line 124; references Mock, SystemExit, raises, jail, uuid
• test_execute_jail_success — def at line 130; references jail, uuid
• test_marked_as_started — def at line 134; references append, Mock, uuid, jail
• store_result — def at line 137; references append, Mock, uuid, jail
• test_execute_jail_failure — def at line 154; references jail, uuid
• test_execute_task_ignore_result — def at line 161; references task, uuid, jail
• ignores_result — def at line 163; references uuid, jail
• test_execute_request_ignore_result — def at line 171; references task, uuid, jail
• ignores_result — def at line 173; references uuid, jail
• test_Request — class at line 185; references task_message_from_sig, copy, pop, Request, Mock, get_request, set
• get_request — def at line 187; references task_message_from_sig, copy, pop, Request, Mock, set
• test_shadow — def at line 211; references get_request, set
• test_args — def at line 215; references get_request
• test_kwargs — def at line 220
• test_info_function — def at line 225
• test_no_shadow_header — def at line 247; references get_request
• test_invalid_eta_raises_InvalidTaskError — def at line 252; references raises, get_request, set
• test_invalid_expires_raises_InvalidTaskError — def at line 256; references raises, get_request, set
• test_valid_expires_with_utc_makes_aware — def at line 260; references patch, get_request, set, assert_called
• test_maybe_expire_when_expires_is_None — def at line 266; references get_request, maybe_expire
• test_on_retry_acks_if_late — def at line 270; references get_request, on_retry, Mock, assert_called_with
• test_on_failure_Terminated — def at line 276; references Terminated, ExceptionInfo, get_request, on_failure, assert_called_with
• test_on_failure_propagates_MemoryError — def at line 290; references MemoryError, ExceptionInfo, get_request, raises, on_failure
• test_on_failure_Ignore_acknowledges — def at line 301; references Ignore, ExceptionInfo, get_request, on_failure, assert_called_with
• test_on_failure_Reject_rejects — def at line 312; references Reject, ExceptionInfo, get_request, Mock, on_failure, assert_called_with
• test_on_failure_Reject_marks_as_failure — def at line 326; references Reject, ExceptionInfo, get_request, Mock, connect, on_failure, disconnect, assert_called_once, getattr, isinstance, assert_called_with, any
• test_on_failure_Reject_respects_send_failed_event — def at line 361; references Reject, ExceptionInfo, get_request, Mock, on_failure, assert_called_once, any
• test_on_failure_Reject_marks_as_failure_when_already_acked — def at line 379; references Reject, ExceptionInfo, get_request, Mock, on_failure, assert_called_once
• test_on_failure_Reject_rejects_with_requeue — def at line 395; references Reject, ExceptionInfo, get_request, Mock, on_failure, assert_called_with, assert_not_called, any
• test_on_failure_WorkerLostError_rejects_with_requeue — def at line 416; references WorkerLostError, ExceptionInfo, get_request, Mock, on_failure, assert_called_with, assert_not_called
• test_on_failure_WorkerLostError_redelivered_None — def at line 434; references WorkerLostError, ExceptionInfo, get_request, Mock, on_failure, assert_called_with, assert_not_called
• test_on_failure_WorkerLostError_redelivered_True — def at line 452; references WorkerLostError, ExceptionInfo, get_request, Mock, assert_signal_called, on_failure, assert_called_once_with
• test_on_failure_TimeLimitExceeded_acks — def at line 481; references TimeLimitExceeded, ExceptionInfo, get_request, Mock, on_failure, assert_called_with, assert_called_once_with
• test_on_failure_TimeLimitExceeded_rejects_with_requeue — def at line 504; references TimeLimitExceeded, ExceptionInfo, get_request, Mock, on_failure, assert_called_with, assert_not_called
• test_tzlocal_is_cached — def at line 524; references get_request
• test_ignore_result_from_request_true — def at line 529; references get_request, set
• test_ignore_result_from_request_false — def at line 533; references get_request, set
• test_ignore_result_default_from_task_false — def at line 537; references get_request
• test_ignore_result_default_from_task_true — def at line 541; references get_request
• test_ignore_result_request_overrides_task_true — def at line 549; references get_request, set
• test_task_wrapper_repr — def at line 557; references repr, xRequest
• test_sets_store_errors — def at line 560; references xRequest, 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_once
• test_store_errors_default — def at line 569; references xRequest, 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_once
• test_store_errors_task_ignore_result — def at line 574; references xRequest, 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_once
• test_store_errors_request_overrides_task_ignore_result — def at line 579; references task_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_once
• test_ignore_result_from_request_none — def at line 590; references task_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_once
• test_send_event — def at line 598; references xRequest, 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, now
• test_send_events__disabled_at_task_level — def at line 604; references xRequest, 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, now
• test_on_retry — def at line 611; references get_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, timedelta
• test_compat_properties — def at line 633; references xRequest, 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, parametrize
• test_terminate__pool_ref — def at line 642; references 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, xRequest, add, parametrize
• test_terminate__task_started — def at line 659; references Mock, 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, parametrize
• test_cancel__pool_ref — def at line 671; references Mock, 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, parametrize
• test_terminate__task_reserved — def at line 688; references Mock, 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, parametrize
• test_cancel__task_started — def at line 697; references Mock, 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, parametrize
• test_cancel__task_reserved — def at line 710; references Mock, 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, parametrize
• test_cancel__emit_retry_true — def at line 718; references Mock, 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, parametrize
• test_cancel__emit_retry_false — def at line 736; references Mock, get_request, monotonic, cancel, assert_called_with, assert_not_called, set, now, timedelta, assert_signal_called, revoked, set_current, get_status, xRequest, add, parametrize
• test_revoked_expires_expired — def at line 751; references get_request, set, now, timedelta, assert_signal_called, revoked, set_current, get_status, xRequest, add, parametrize
• test_revoked_expires_not_expired — def at line 763; references xRequest, now, timedelta, revoked, get_status, assert_signal_called, add, parametrize
• test_revoked_expires_ignore_result — def at line 771; references xRequest, now, timedelta, revoked, get_status, assert_signal_called, add, parametrize
• test_already_revoked — def at line 780; references xRequest, revoked, assert_signal_called, add, parametrize

File-level call references

• import — line 15
• task — line 33
• KeyError — line 47
• Mock — line 55
• TaskMessage — line 57
• Request — line 60
• mro_lookup — line 83
• update — line 94
• trace_task — line 97
• Exception — line 106
• Retry — line 108
• patching — line 115
• uuid — line 118
• jail — line 119
• assert_called — line 121
• SystemExit — line 126
• raises — line 127
• append — line 139
• isinstance — line 158
• AsyncResult — line 169
• ready — line 169
• task_message_from_sig — line 193
• copy — line 195
• pop — line 198
• get_request — line 212
• set — line 213
• range — line 229
• str — line 230
• join — line 230
• choice — line 231
• info — line 233
• get — line 233
• list — line 241
• patch — line 261
• maybe_expire — line 268
• on_retry — line 273
• assert_called_with — line 274
• Terminated — line 279
• ExceptionInfo — line 281
• on_failure — line 284
• MemoryError — line 293
• Ignore — line 304
• Reject — line 315
• connect — line 338
• disconnect — line 342
• assert_called_once — line 343
• getattr — line 346
• any — line 356
• assert_not_called — line 410
• WorkerLostError — line 418
• assert_signal_called — line 464
• assert_called_once_with — line 476
• TimeLimitExceeded — line 483
• repr — line 558
• xRequest — line 558
• send_event — line 601
• safe_repr — line 622
• safe_str — line 623
• monotonic — line 650
• terminate — line 652
• _apply_result — line 653
• cancel — line 681
• now — line 753
• timedelta — line 753
• revoked — line 758
• set_current — line 760
• get_status — line 761
• add — line 790
• parametrize — line 795
• clear — line 806
• keys — line 809
• execute — line 825
• execute_using_pool — line 841
• on_accepted — line 845
• getpid — line 845
• time — line 874
• on_success — line 879
• get_ei — line 932
• on_timeout — line 1202
• after_return_mock — line 1367
• TaskWithAfterReturn — line 1369
• register — line 1370
• original_mark — line 1396
• object — line 1398
• setup_worker_optimizations — line 1409
• len — line 1413
• build_tracer — line 1415
• fast_trace_task — line 1419
• reset_worker_optimizations — line 1427
• delattr — line 1429
• trace_task_ret — line 1430
• warns — line 1473
• push_request — line 1479
• ValueError — line 1481
• TraceInfo — line 1486
• handle_retry — line 1487
• pop_request — line 1496
• handle_failure — line 1507
• get_task_meta — line 1554
• BaseDictBackend — line 1565
• type — line 1659
• _test_on_failure — line 1666
• from_utf8 — line 1673
• reject — line 1688
• reset_mock — line 1693
• super — line 1714
• setup_method — line 1714
• create_request_cls — line 1717
• zRequest — line 1731
• exc — line 1738
• apply_async — line 1814
• weakref_ref — line 1815
• hybrid_to_proto2 — line 1863

Source: t/unit/worker/test_request.py