Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › postman › test_sync_router

Tests reference — tests/postman/test_sync_router.py

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

Prose pending.

tests/postman/test_sync_router.py

source · 18 tests · 373 lines

Tests for SyncRouterMixin (Postman.route_sync) behaviour.

Covers: postman.postman, core.packet/ (package)

Kind Name Line Description
class TestRouteSyncDispatch 73
method TestRouteSyncDispatch.test_route_sync_sync_handler 74
method TestRouteSyncDispatch.test_route_sync_async_handler 88 route_sync dispatches an async handler from a sync context.
method TestRouteSyncDispatch.test_route_sync_no_handler 102
method TestRouteSyncDispatch.test_route_sync_with_response 107
class TestRouteSyncDedupFallback 126
method TestRouteSyncDedupFallback.test_duplicate_message_returns_none 127 A duplicate packet (same deterministic id) is dropped in-memory.
method TestRouteSyncDedupFallback.test_is_duplicate_sync_fallback_tracks_new_ids 149
class TestGetThreadPacketsFallback 157
method TestGetThreadPacketsFallback.test_get_thread_packets_memory 158
method TestGetThreadPacketsFallback.test_get_thread_packets_redis_error_falls_back 173 A Redis error during read falls back to the in-memory log.
class TestGetLog 192
method TestGetLog.test_get_log_returns_reprs 193
class TestRedisBackedSuccessPaths 201 Exercises the Redis-success branches of SyncRouterMixin.
method TestRedisBackedSuccessPaths.test_is_duplicate_sync_uses_real_redis 227
method TestRedisBackedSuccessPaths.test_persist_to_thread_sync_writes_to_redis 236
method TestRedisBackedSuccessPaths.test_enqueue_then_dequeue_sync_round_trips_through_redis 246
method TestRedisBackedSuccessPaths.test_get_thread_packets_reads_from_redis 259
class TestRedisErrorFallback 299 Exercises the except Exception fallback branches of
method TestRedisErrorFallback.test_is_duplicate_sync_redis_error_returns_false 307
method TestRedisErrorFallback.test_persist_to_thread_sync_redis_error_is_swallowed 314
method TestRedisErrorFallback.test_enqueue_sync_redis_error_falls_back_to_memory 323
method TestRedisErrorFallback.test_dequeue_sync_redis_error_returns_none 335
class TestRunAsyncHandlerRunningLoop 343 Covers the branch in _run_async_handler taken when a loop is
method TestRunAsyncHandlerRunningLoop.test_dispatch_async_handler_from_running_loop 351