Skip to content

Commit 0897f5d

Browse files
committed
Add process exit on task registry init failure
1 parent 302aaed commit 0897f5d

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

crates/fluxqueue-worker/src/worker.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,10 @@ pub async fn run_worker(
2424
})?;
2525
let redis_client = Arc::new(redis_client);
2626

27-
let task_registry = Arc::new(TaskRegistry::new(&tasks_module_path, &queue_name)?);
27+
let task_registry = Arc::new(TaskRegistry::new(&tasks_module_path, &queue_name).map_err(|e| {
28+
tracing::error!("{}", e);
29+
std::process::exit(1);
30+
})?);
2831
let registered_tasks = task_registry.get_registered_tasks()?;
2932
let registered_contexts = task_registry.get_registered_contexts()?;
3033

0 commit comments

Comments
 (0)