|
|
@@ -82,7 +82,7 @@ impl<W: Worker + 'static> WorkerManager<W> {
|
|
|
let worker_for_thread = self.worker.clone();
|
|
|
let worker_in_scope = self.is_running.clone();
|
|
|
thread::spawn(|| {
|
|
|
- let rt = Runtime::new().unwrap();
|
|
|
+ let rt = Runtime::new().expect("Failed to create tokio runtime in worker.rs");
|
|
|
rt.block_on(async move {
|
|
|
let mut last_time = Utc::now();
|
|
|
loop {
|
