pytc.test.test_async_hdf5_writer¶
Unit tests for pytc.utils.gpu_pipeline._AsyncHDF5Writer.
These tests exercise the writer purely against in-memory callables, with no real HDF5 file I/O — the contract we care about is:
FIFO ordering of submitted jobs.
drain()blocks until the queue is empty.Errors raised inside the worker are latched and re-raised on the next
submit()/drain()/close().After the first error the worker drops any remaining queued work so the main thread cannot deadlock on a full queue.
Back-pressure: with
max_pending=1and a slow worker,submit()blocks once the queue is full.The context-manager protocol drains on clean exit and always joins the worker thread.
Classes