from svc_infra.jobs.runner import WorkerRunner
Cooperative worker loop with graceful stop. - start(): begin polling the queue and processing jobs - stop(grace_seconds): signal stop, wait up to grace for current job to finish