We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 487e7a5 commit f4202b6Copy full SHA for f4202b6
src/scheduler/scheduler.rs
@@ -81,7 +81,8 @@ impl<C: Context> Scheduler<C> {
81
let self_mut = unsafe { Arc::get_mut_unchecked(&mut self_mut) };
82
83
self_mut.context = Some(context);
84
- self_mut.coordinator_worker = Some(RwLock::new(Worker::new(0, Arc::downgrade(&self), true)));
+ self_mut.coordinator_worker =
85
+ Some(RwLock::new(Worker::new(0, Arc::downgrade(&self), true)));
86
self_mut.worker_group = Some(WorkerGroup::new(num_workers, Arc::downgrade(&self)));
87
self.worker_group
88
.as_ref()
0 commit comments