The worker loop: drains activateJobsStream, running the handler for each job with bounded concurrency (the backpressure knob), and acknowledging via completeJob/failJob/throwJobError per the handler's typed outcome.
concurrency
completeJob
failJob
throwJobError
The worker loop: drains activateJobsStream, running the handler for each job with bounded
concurrency(the backpressure knob), and acknowledging viacompleteJob/failJob/throwJobErrorper the handler's typed outcome.