Source symbols: t/integration/test_tasks.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: 71
• Referenced calls: 68

Declared symbols

• flaky — def at line 30; references _timeout, _flaky, system, set_start_method, ClassBasedAutoRetryTask, register_task, delay, get, range, append, ready, successful, add, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep
• set_multiprocessing_start_method — def at line 34; references system, set_start_method, ClassBasedAutoRetryTask, register_task, delay, get, range, append, ready, successful, add, skip, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_class_based_tasks — class at line 44; references ClassBasedAutoRetryTask, register_task, delay, get, range, append, ready, successful, add, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_class_based_task_retried — def at line 47; references ClassBasedAutoRetryTask, register_task, delay, get, range, append, ready, successful, add, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• _producer — def at line 55; references range, append, delay, get, ready, successful, add, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_tasks — class at line 69; references add, range, append, delay, get, ready, successful, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_simple_call — def at line 71; references add, range, append, delay, get, ready, successful, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_basic_task — def at line 77; references range, append, delay, get, ready, successful, skip, set_multiprocessing_start_method, Pool, list, ThreadPool, apply_async, sleep, raises, failed
• test_multiprocess_producer — def at line 103; references set_multiprocessing_start_method, Pool, range, list, skip, ThreadPool, apply_async, get, sleep, delay, raises, ready, failed, successful, append
• test_multithread_producer — def at line 114; references set_multiprocessing_start_method, ThreadPool, range, list, apply_async, get, sleep, delay, raises, ready, failed, successful, append
• test_ignore_result — def at line 124; references apply_async, get, sleep, delay, raises, ready, failed, successful, range, append
• test_reject_without_requeue_stores_failure — def at line 134; references delay, raises, get, ready, failed, successful, range, append
• test_reject_with_requeue_redelivers_and_succeeds — def at line 144; references delay, get, ready, failed, successful, range, append
• test_pydantic_annotations — def at line 153; references range, append, delay
• test_pydantic_string_annotations — def at line 167; references range, append, delay
• test_timeout — def at line 181; references delay, raises, get, timeout, range, apply_async, ready, failed, successful, now, timedelta, perf_counter, sleep, assert, revoke, uuid4
• test_expired — def at line 189; references range, delay, apply_async, raises, get, ready, failed, successful, now, timedelta, perf_counter, sleep, assert, revoke, uuid4
• test_eta — def at line 216; references perf_counter, apply_async, sleep, ready, get, assert, now, timedelta, delay, raises, failed, successful, range, revoke, uuid4
• test_fail — def at line 245; references delay, raises, get, ready, failed, successful, range, apply_async, revoke, uuid4
• test_revoked — def at line 256; references range, delay, apply_async, revoke, raises, get, ready, failed, successful, uuid4
• test_revoked_by_headers_simple_canvas — def at line 271; references uuid4
• MonitoringIdStampingVisitor — class at line 275
• on_signature — def at line 276
• test_revoked_by_headers_complex_canvas — def at line 308; references ensure_chords_allowed, skip, uuid4, wait_until_idle, isinstance
• MonitoringIdStampingVisitor — class at line 323
• on_signature — def at line 324
• test_revoke_by_stamped_headers_no_match — def at line 359; references revoke_by_stamped_headers
• test_wrong_arguments — def at line 370; references raises, add, delay, get, xfail, monotonic, sleep, AssertionError
• test_retry — def at line 400; references delay, monotonic, sleep, AssertionError, raises, get
• test_retry_with_unpickleable_exception — def at line 433; references delay
• test_fail_with_unpickleable_exception — def at line 474; references delay, get, fail, str, skip, assert_accepted, apply_async
• test_task_accepted — def at line 500; references delay, assert_accepted, get, apply_async
• test_task_retried_once — def at line 506; references delay, get, apply_async
• test_task_retried_once_with_expires — def at line 511; references delay, get, apply_async
• test_task_retried_priority — def at line 516; references apply_async, get
• test_task_retried_headers — def at line 521; references apply_async
• test_unicode_task — def at line 528; references join, group, range, apply_async, get, raises, task
• test_properties — def at line 535; references apply_async, get, raises, task
• test_soft_time_limit_exceeding_time_limit — def at line 540; references raises, apply_async, get, task
• test_request_time_limits_set_via_apply_async — def at line 549; references apply_async, get, task
• test_request_time_limits_none_when_not_configured — def at line 558; references apply_async, get, task
• test_request_time_limits_from_task_declaration — def at line 567; references apply_async, get, task
• test_apply_async_time_limits_override_task_declaration — def at line 576; references apply_async, get, task
• test_apply_tasks — class at line 585; references task
• test_apply_single_task_ids — def at line 588; references task
• single_apply_task — def at line 591
• test_apply_nested_parent_child_relationship — def at line 605; references task
• grandchild_task — def at line 609
• child_task — def at line 618; references apply, get
• parent_task — def at line 631; references apply, get
• test_trace_log_arguments — class at line 665; references sleep
• assert_trace_log — def at line 669; references sleep
• call_task_with_reprs — def at line 680; references set, delay, get, successful, assert_trace_log, raises, failed, fixture, startswith, skip, get_active_redis_channels, encode
• test_task_success — def at line 684; references call_task_with_reprs, get, successful, assert_trace_log, raises, failed, fixture, startswith, skip, get_active_redis_channels, delay, set, encode
• test_task_failed — def at line 700; references call_task_with_reprs, raises, get, failed, assert_trace_log, fixture, startswith, skip, get_active_redis_channels, delay, set, encode
• test_task_redis_result_backend — class at line 716; references fixture, startswith, skip, get_active_redis_channels, delay, set, encode
• manager — def at line 718; references startswith, skip, get_active_redis_channels, delay, set, encode
• test_ignoring_result_no_subscriptions — def at line 724; references get_active_redis_channels, delay, set, encode
• test_asyncresult_forget_cancels_subscription — def at line 734; references get_active_redis_channels, delay, set, encode
• test_asyncresult_get_cancels_subscription — def at line 747; references get_active_redis_channels, delay, set, encode
• test_task_replacement — class at line 760; references delay, get, startswith, skip, get_redis_connection, delete, list, lrange
• test_replaced_task_nesting_level_0 — def at line 761; references delay, get
• task_received_handler — def at line 763; references delay, get
• test_replaced_task_nesting_level_1 — def at line 778; references startswith, skip, get_redis_connection, delete, delay, get, list, lrange
• task_received_handler — def at line 786; references delay, get, list, lrange
• test_replaced_task_nesting_chain — def at line 803; references startswith, skip, get_redis_connection, delete, delay, get, list, lrange
• task_received_handler — def at line 811; references delay, get, list, lrange
• test_pool_acquire_timeout — class at line 829; references delay, get, ThreadPoolExecutor, submit, range, as_completed, append, result
• test_task_succeeds_with_pool_timeout_configured — def at line 833; references delay, get
• test_pool_timeout_none_blocks_successfully — def at line 845; references delay, get
• test_concurrent_apply_async_with_timeout — def at line 853; references ThreadPoolExecutor, submit, range, as_completed, append, result, get

File-level call references

• import — line 18
• flaky — line 26
• timeout — line 27
• _timeout — line 31
• _flaky — line 31
• system — line 36
• set_start_method — line 38
• ClassBasedAutoRetryTask — line 49
• register_task — line 50
• delay — line 51
• get — line 52
• range — line 58
• append — line 59
• ready — line 64
• successful — line 65
• add — line 73
• skip — line 102
• set_multiprocessing_start_method — line 105
• Pool — line 108
• list — line 110
• ThreadPool — line 119
• apply_async — line 126
• sleep — line 130
• raises — line 136
• failed — line 140
• now — line 207
• timedelta — line 207
• perf_counter — line 218
• assert — line 229
• revoke — line 263
• uuid4 — line 273
• stamp — line 281
• MonitoringIdStampingVisitor — line 281
• freeze — line 282
• revoke_by_stamped_headers — line 283
• clear — line 304
• ensure_chords_allowed — line 311
• wait_until_idle — line 319
• isinstance — line 321
• group — line 332
• chord — line 333
• chain — line 335
• test — line 349
• keys — line 367
• xfail — line 395
• monotonic — line 405
• AssertionError — line 412
• str — line 468
• fail — line 486
• assert_accepted — line 503
• join — line 529
• task — line 590
• apply — line 598
• set — line 681
• call_task_with_reprs — line 685
• assert_trace_log — line 690
• fixture — line 717
• startswith — line 719
• get_active_redis_channels — line 725
• encode — line 739
• forget — line 741
• get_redis_connection — line 782
• delete — line 783
• lrange — line 799
• ThreadPoolExecutor — line 862
• submit — line 864
• as_completed — line 867
• result — line 868

Source: t/integration/test_tasks.py