Task Summary
amber/src/main/python/core/architecture/packaging/input_manager.py is the Python worker's input-side bookkeeping (instantiated per worker in Context).
Note the Scala engine's InputManager was covered by #5450 / PR #5451; this task is its untested Python counterpart. Nothing in amber/src/test/python imports this module — existing runnables tests exercise it only indirectly through MainLoop. All of the above is unit-testable directly with an InternalQueue, in-memory Schema/ArrowTableTupleProvider inputs, and stubbed reader runnables.
Task Type
Task Summary
amber/src/main/python/core/architecture/packaging/input_manager.pyis the Python worker's input-side bookkeeping (instantiated per worker inContext).Note the Scala engine's
InputManagerwas covered by #5450 / PR #5451; this task is its untested Python counterpart. Nothing inamber/src/test/pythonimports this module — existing runnables tests exercise it only indirectly throughMainLoop. All of the above is unit-testable directly with anInternalQueue, in-memorySchema/ArrowTableTupleProviderinputs, and stubbed reader runnables.Task Type