(&mut self, senders: &Senders, now: DateTime<Utc>)
| 331 | } |
| 332 | |
| 333 | pub fn check_termination(&mut self, senders: &Senders, now: DateTime<Utc>) { |
| 334 | if self.has_no_active_tasks() { |
| 335 | if self.is_open() { |
| 336 | senders.events.on_job_idle(self.job_id, now); |
| 337 | } else { |
| 338 | self.completion_date = Some(now); |
| 339 | senders.events.on_job_completed(self.job_id, now); |
| 340 | } |
| 341 | } |
| 342 | } |
| 343 | |
| 344 | pub fn set_finished_state( |
| 345 | &mut self, |
no test coverage detected