pub async fn run_worker_loop_with_observer(
pool: DbPool,
registry: JobRegistry,
config: JobsConfig,
shutdown: Receiver<bool>,
observers: JobLifecycleObservers,
) -> RuntimeLoopExitpub async fn run_worker_loop_with_observer(
pool: DbPool,
registry: JobRegistry,
config: JobsConfig,
shutdown: Receiver<bool>,
observers: JobLifecycleObservers,
) -> RuntimeLoopExit