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=1 and 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