Source symbols: t/integration/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: 79
• Referenced calls: 47

Declared symbols

• get_redis_connection — def at line 21; references get, StrictRedis, get_task_logger, control_command
• pidbox_reset_error — def at line 33; references RuntimeError
• identity — def at line 38
• add — def at line 44
• mul — def at line 53
• write_to_file_and_return_int — def at line 59; references open, write, str, shared_task
• add_not_typed — def at line 67; references shared_task
• add_ignore_result — def at line 73
• raise_error — def at line 79; references ValueError
• chain_add — def at line 85; references apply_async
• chord_add — def at line 92; references chord, apply_async
• delayed_sum — def at line 97; references sleep, sum
• delayed_sum_with_soft_guard — def at line 106; references sleep, sum
• tsum — def at line 116; references sum
• xsum — def at line 122; references sum, isinstance, shared_task
• add_replaced — def at line 128; references replace, shared_task
• replace_with_chain — def at line 134; references chain, set, link, replace, shared_task
• replace_with_chain_which_raises — def at line 146; references chain, set, link_error, replace, shared_task
• replace_with_empty_chain — def at line 158; references replace, chain, shared_task, group, add_to_chord, warning, print, sleep, getattr, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, test_chain, isinstance, hash, TypeError
• add_to_all — def at line 163; references replace, group, shared_task, add_to_chord, warning, print, sleep, getattr, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, test_chain, isinstance, hash, TypeError
• add_to_all_to_chord — def at line 170; references add_to_chord, shared_task, group, warning, print, sleep, getattr, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, test_chain, isinstance, hash, TypeError
• add_chord_to_chord — def at line 177; references add_to_chord, group, warning, print, sleep, shared_task, getattr, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, test_chain, isinstance, hash, TypeError
• print_unicode — def at line 184; references warning, print, sleep, shared_task, getattr, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super
• return_exception — def at line 191; references sleep, shared_task, getattr, print, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__
• sleeping — def at line 197; references sleep, shared_task, getattr, print, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__
• ids — def at line 203; references shared_task, getattr, print, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__
• collect_ids — def at line 210; references shared_task, getattr, print, delattr, retry, ExpectedException, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__
• retry — def at line 220; references getattr, print, delattr, ExpectedException, shared_task, UnpickleableException, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__
• retry_unpickleable — def at line 238; references retry, UnpickleableException, shared_task, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException
• retry_once — def at line 244; references retry, shared_task, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• retry_once_priority — def at line 254; references retry, shared_task, get_redis_connection, rpush, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• retry_once_headers — def at line 264; references retry, get_redis_connection, rpush, shared_task, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• redis_echo — def at line 274; references get_redis_connection, rpush, shared_task, incr, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• redis_echo_group_id — def at line 281; references get_redis_connection, rpush, incr, shared_task, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• redis_count — def at line 287; references get_redis_connection, incr, shared_task, rpush, chain, replace, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• second_order_replace1 — def at line 294; references get_redis_connection, rpush, chain, replace, shared_task, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• second_order_replace2 — def at line 306; references get_redis_connection, rpush, chain, replace, shared_task, group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, UnpickleableException
• build_chain_inside_task — def at line 318; references group, test_chain, isinstance, hash, TypeError, super, __init__, ExpectedException, shared_task, UnpickleableException, replace
• ExpectedException — class at line 337; references isinstance, hash, TypeError, super, __init__, shared_task, UnpickleableException, replace
• __eq__ — def at line 340; references isinstance, hash, TypeError, super, __init__, ExpectedException, shared_task, UnpickleableException, replace
• __hash__ — def at line 347; references hash, TypeError, super, __init__, ExpectedException, shared_task, UnpickleableException, replace
• UnpickleableException — class at line 351; references TypeError, super, __init__, ExpectedException, shared_task, replace
• __init__ — def at line 354; references TypeError, super, ExpectedException, shared_task, UnpickleableException, replace
• fail — def at line 366; references ExpectedException, shared_task, UnpickleableException, replace
• fail_unpickleable — def at line 373; references UnpickleableException, shared_task, replace
• fail_replaced — def at line 379; references replace, shared_task
• return_priority — def at line 385; references shared_task
• return_properties — def at line 390
• ClassBasedAutoRetryTask — class at line 394
• run — def at line 400; references ValueError, chain, group, chord, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chain_chain — def at line 409; references chain, group, chord, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chain_group — def at line 414; references chain, group, chord, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chain_chord — def at line 419; references chain, chord, group, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_group_chain — def at line 424; references group, chain, chord, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_group_group — def at line 429; references group, chord, chain, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_group_chord — def at line 434; references group, chord, chain, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chord_chain — def at line 439; references chord, chain, group, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chord_group — def at line 444; references chord, group, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• return_nested_signature_chord_chord — def at line 449; references chord, from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• rebuild_signature — def at line 454; references from_dict, isinstance, TypeError, _recurse, redis_count, shared_task, AddResultModel
• _recurse — def at line 457; references isinstance, TypeError, redis_count, shared_task, AddResultModel
• errback_old_style — def at line 471; references redis_count, shared_task, AddResultModel
• errback_new_style — def at line 477; references redis_count, shared_task, AddResultModel
• replaced_with_me — def at line 483; references shared_task, AddResultModel
• AddParameterModel — class at line 487; references shared_task, AddResultModel
• AddResultModel — class at line 492; references shared_task
• add_pydantic — def at line 497; references AddResultModel, shared_task
• add_pydantic_string_annotations — def at line 504; references AddResultModel
• StampOnReplace — class at line 511
• on_signature — def at line 514; references stamp, StampOnReplace, super, on_replace, shared_task, replace, signature, get, store_result, Reject
• StampedTaskOnReplace — class at line 517; references stamp, StampOnReplace, super, on_replace, shared_task, replace, signature, get, store_result, Reject
• on_replace — def at line 520; references stamp, StampOnReplace, super, shared_task, replace, signature, get, store_result, Reject
• replace_with_stamped_task — def at line 525; references replace, signature, shared_task, get, store_result, Reject
• store_success_then_reject — def at line 532; references get, store_result, Reject, shared_task
• reject_then_succeed — def at line 545; references get, Reject, shared_task
• reject_without_requeue — def at line 553; references Reject, shared_task
• soft_time_limit_must_exceed_time_limit — def at line 559; references shared_task
• return_request_time_limits — def at line 564
• task_with_declared_time_limits — def at line 573

File-level call references

• get — line 24
• StrictRedis — line 26
• get_task_logger — line 29
• control_command — line 32
• RuntimeError — line 34
• open — line 60
• write — line 61
• str — line 61
• shared_task — line 66
• ValueError — line 81
• apply_async — line 88
• chord — line 93
• sleep — line 101
• sum — line 102
• isinstance — line 124
• replace — line 130
• chain — line 135
• set — line 139
• link — line 140
• link_error — line 152
• group — line 166
• add_to_chord — line 172
• warning — line 186
• print — line 187
• getattr — line 227
• delattr — line 230
• retry — line 234
• ExpectedException — line 234
• UnpickleableException — line 240
• get_redis_connection — line 276
• rpush — line 277
• incr — line 290
• test_chain — line 333
• hash — line 348
• TypeError — line 359
• super — line 361
• __init__ — line 361
• from_dict — line 455
• _recurse — line 463
• redis_count — line 472
• AddResultModel — line 500
• stamp — line 521
• StampOnReplace — line 521
• on_replace — line 522
• signature — line 528
• store_result — line 537
• Reject — line 538

Source: t/integration/tasks.py