Source symbols: t/unit/app/test_amqp.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: 64
• Referenced calls: 38

Declared symbols

• test_TaskConsumer — class at line 12; references acquire, TaskConsumer
• test_accept_content — def at line 14; references acquire, TaskConsumer
• test_ProducerPool — class at line 25; references delattr, acquire, release
• test_setup_nolimit — def at line 27; references delattr, acquire, release
• test_setup — def at line 45; references delattr, acquire, release
• test_Queues — class at line 68
• test_queues_format — def at line 70
• test_with_defaults — def at line 74; references Queues
• test_add — def at line 77; references Queues, add, isinstance, Exchange, Queue, select, select_add, sorted, keys, deselect, list
• test_setitem_adds_default_exchange — def at line 84; references Queues, Exchange, Queue, select, select_add, sorted, keys, deselect, add, list
• test_select_add — def at line 92; references Queues, select, select_add, sorted, keys, Queue, deselect, add, Exchange, list
• test_select_add_without_selection_extends_default — def at line 98; references Queues, Queue, select_add, sorted, keys, select, deselect, add, Exchange, list
• test_deselect — def at line 104; references Queues, select, deselect, sorted, keys, Queue, add, Exchange, list
• test_deselect_without_explicit_consume_selection_removes_excluded_queue — def at line 110; references Queues, Queue, deselect, sorted, keys, add, Exchange, select, list
• test_deselect_without_explicit_consume_selection_keeps_routing_only_queue_unconsumed — def at line 116; references Queues, Queue, add, deselect, sorted, keys, Exchange, select, list
• test_add_default_exchange — def at line 123; references Exchange, Queues, add, Queue, select, list, deselect
• test_alias — def at line 129; references Queues, add, Queue, select, list, deselect
• test_deselect_by_real_name_removes_queue_selected_by_alias — def at line 134; references Queues, add, Queue, select, list, deselect
• test_with_max_priority — def at line 162; references Queues, add, new_missing
• test_missing_queue_quorum — def at line 167; references Queues, new_missing
• test_default_queues — class at line 177; references parametrize
• test_setting_default_queue — def at line 186
• test_default_exchange — class at line 206; references parametrize, Queue
• test_setting_default_exchange — def at line 212; references Queue
• test_setting_default_exchange_type — def at line 226; references Queue
• test_AMQP_proto1 — class at line 235; references raises, as_task_v1, uuid, as_task_v2, Queues
• test_kwargs_must_be_mapping — def at line 237; references raises, as_task_v1, uuid, as_task_v2, Queues
• test_args_must_be_list — def at line 241; references raises, as_task_v1, uuid, as_task_v2, Queues
• test_countdown_negative — def at line 245; references raises, as_task_v1, uuid, as_task_v2, Queues
• test_as_task_message_without_utc — def at line 249; references as_task_v1, uuid, as_task_v2, raises, Queues
• test_AMQP_Base — class at line 254; references as_task_v2, uuid, raises, Queues
• setup_method — def at line 255; references as_task_v2, uuid, raises, Queues
• test_AMQP — class at line 264; references raises, as_task_v2, uuid, Queues
• test_kwargs_must_be_mapping — def at line 266; references raises, as_task_v2, uuid, Queues
• test_args_must_be_list — def at line 270; references raises, as_task_v2, uuid, Queues
• test_countdown_negative — def at line 274; references raises, as_task_v2, uuid, Queues
• test_Queues__with_max_priority — def at line 278; references Queues
• test_send_task_message__no_kwargs — def at line 282; references send_task_message, Mock
• test_send_task_message__properties — def at line 285; references Mock, send_task_message
• test_send_task_message__headers — def at line 293; references Mock, send_task_message
• test_send_task_message__queue_string — def at line 302; references Mock, send_task_message, Queue
• test_send_task_message__no_default_queue — def at line 312; references Queue
• test_send_task_message__broadcast_without_exchange — def at line 326; references Mock, send_task_message, Broadcast, assert_called, patch, update
• test_send_event_exchange_direct_with_exchange — def at line 339; references Mock, send_task_message, assert_called, patch, update
• test_send_event_exchange_direct_with_routing_key — def at line 350; references Mock, send_task_message, assert_called, patch, update
• test_send_event_exchange_string — def at line 361; references Mock, send_task_message, assert_called, patch, update
• test_send_task_message__with_delivery_mode — def at line 373; references Mock, send_task_message, patch, update
• test_send_task_message__with_timeout — def at line 381; references Mock, send_task_message, patch, update
• test_send_task_message__with_confirm_timeout — def at line 389; references Mock, send_task_message, patch, update
• test_send_task_message__with_receivers — def at line 397; references Mock, patch, send_task_message, update
• test_routes — def at line 402; references update
• update_conf_runtime_for_tasks_queues — def at line 407; references update
• test_create_missing_queue_type_from_conf — def at line 416; references pop
• test_create_missing_queue_type_explicit_param — def at line 424; references Queues
• test_as_task_v2 — class at line 433; references raises, as_task_v2, uuid, to_utc, now, astimezone, timedelta, isoformat, Mock, send_task_message, utf8dict
• test_raises_if_args_is_not_tuple — def at line 435; references raises, as_task_v2, uuid
• test_raises_if_kwargs_is_not_mapping — def at line 439; references raises, as_task_v2, uuid
• test_countdown_to_eta — def at line 443; references to_utc, now, astimezone, as_task_v2, uuid, timedelta, isoformat
• test_expires_to_datetime — def at line 450; references to_utc, now, astimezone, as_task_v2, uuid, timedelta, isoformat
• test_eta_to_datetime — def at line 458; references now, as_task_v2, uuid, isoformat
• test_compression — def at line 465; references Mock, send_task_message
• test_compression_override — def at line 475; references Mock, send_task_message
• test_callbacks_errbacks_chord — def at line 485; references as_task_v2, uuid, utf8dict
• t — def at line 487; references as_task_v2, uuid, utf8dict

File-level call references

• acquire — line 15
• TaskConsumer — line 17
• delattr — line 30
• release — line 40
• format — line 72
• Queues — line 75
• add — line 79
• isinstance — line 81
• Exchange — line 85
• Queue — line 87
• select — line 94
• select_add — line 95
• sorted — line 96
• keys — line 96
• deselect — line 107
• list — line 139
• parametrize — line 145
• new_missing — line 171
• dict — line 193
• len — line 194
• raises — line 238
• as_task_v1 — line 239
• uuid — line 239
• as_task_v2 — line 256
• send_task_message — line 283
• Mock — line 283
• Broadcast — line 331
• assert_called — line 334
• patch — line 399
• update — line 408
• send_task — line 409
• pop — line 419
• to_utc — line 444
• now — line 444
• astimezone — line 444
• timedelta — line 448
• isoformat — line 448
• utf8dict — line 497

Source: t/unit/app/test_amqp.py