prcs logic fixed
parent
0d68efd461
commit
28092d945a
|
|
@ -82,15 +82,15 @@ pub mod v2 {
|
||||||
ProcessState::Holding => {
|
ProcessState::Holding => {
|
||||||
info!("No negative dependecies events on {} process. Unfreezing ...", self.name);
|
info!("No negative dependecies events on {} process. Unfreezing ...", self.name);
|
||||||
if let Err(er) = unfreeze_process(self.name).await {
|
if let Err(er) = unfreeze_process(self.name).await {
|
||||||
error!("Cannot unfreeze process {} due to {}", self.name, er);
|
error!("Cannot unfreeze process {} : {}", self.name, er);
|
||||||
} else {
|
} else {
|
||||||
self.state = ProcessState::Pending;
|
self.state = ProcessState::Pending;
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
ProcessState::Stopped => {
|
ProcessState::Stopped => {
|
||||||
info!("No negative dependecies events on {} process. Starting ...", self.name);
|
info!("No negative dependecies events on {} process. Starting ...", self.name);
|
||||||
if let Err(_) = start_process(self.name, &self.obj.path).await {
|
if let Err(er) = start_process(self.name, &self.obj.path).await {
|
||||||
error!("Cannot start process {} due to {}", self.name, "system unrecognized error");
|
error!("Cannot start process {} : {}", self.name, er);
|
||||||
} else {
|
} else {
|
||||||
self.state = ProcessState::Pending;
|
self.state = ProcessState::Pending;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue