Orchestrata Ultimate › Tests › Reference › postman › test_coverage_queue_manager

Tests reference — tests/postman/test_coverage_queue_manager.py

Module of tests/postman, split out because the directory page would be too large.

Prose pending.

tests/postman/test_coverage_queue_manager.py

source · 19 tests · 270 lines

Test coverage for queue_manager.py uncovered lines.

Covers: kernel.queue_manager, core.packet/ (package)

Kind Name Line Description
class TestQueueStats 43 Test QueueStats.to_dict() with datetime fields (line 42).
method TestQueueStats.test_to_dict_with_datetimes 46 Test to_dict converts datetime fields to ISO format.
method TestQueueStats.test_to_dict_with_none_datetimes 65 Test to_dict with None datetime fields.
class TestQueueManagerContextManager 82 Test context manager methods (lines 108, 112-113, 117-119).
method TestQueueManagerContextManager.test_context_manager_enter_exit 85 Test aenter and aexit methods.
method TestQueueManagerContextManager.test_aclose 97 Test aclose method explicitly (line 119).
class TestQueueManagerExceptionHandling 111 Test exception handling in QueueManager methods.
method TestQueueManagerExceptionHandling.test_enqueue_redis_connection_error 123 Test enqueue returns False on Redis error (lines 205-210).
method TestQueueManagerExceptionHandling.test_dequeue_redis_connection_error 131 Test dequeue returns None on Redis error (lines 266-270).
method TestQueueManagerExceptionHandling.test_dequeue_with_timeout 138 Test dequeue with timeout > 0 (line 236).
method TestQueueManagerExceptionHandling.test_get_queue_depth_redis_error 146 Test get_queue_depth returns 0 on Redis error (lines 290-292).
method TestQueueManagerExceptionHandling.test_move_to_dead_letter_redis_error 153 Test move_to_dead_letter returns False on Redis error (lines 353-358).
method TestQueueManagerExceptionHandling.test_expire_stale_messages_redis_error 165 Test expire_stale_messages returns 0 on Redis error (lines 408-410).
method TestQueueManagerExceptionHandling.test_get_stats_redis_error 175 Test get_stats returns empty stats on Redis error (lines 462-465).
method TestQueueManagerExceptionHandling.test_inspect_queue_redis_error 184 Test inspect_queue returns [] on Redis error (lines 526-528).
method TestQueueManagerExceptionHandling.test_inspect_queue_with_limit 191 Test inspect_queue limit parameter (line 519).
method TestQueueManagerExceptionHandling.test_close_method 199 Test close method (lines 532-534).
class TestQueueManagerEdgeCases 213 Additional edge case tests for complete coverage.
method TestQueueManagerEdgeCases.test_dequeue_blpop_tuple_handling 225 Test dequeue handling of blpop returning (key, value) tuple (line 245).
method TestQueueManagerEdgeCases.test_expire_stale_messages_scan_loop 233 Test expire_stale_messages scan loop (lines 385-398, 404).
method TestQueueManagerEdgeCases.test_inspect_queue_message_json_none 241 Test inspect_queue when message_json is None (line 504).
method TestQueueManagerEdgeCases.test_context_manager_with_exception 249 Test context manager properly closes on exception.
method TestQueueManagerEdgeCases.test_multiple_close_calls 262 Test that multiple close calls are safe.