In this architecture, a naive implementation of the worker is simple: Request a data chunk from the input queue Wait for the data chunk to read Update the job database Wait for the job database to ...