MCPcopy Create free account
hub / github.com/It4innovations/hyperqueue / check_termination

Method check_termination

crates/hyperqueue/src/server/job.rs:333–342  ·  view source on GitHub ↗
(&mut self, senders: &Senders, now: DateTime<Utc>)

Source from the content-addressed store, hash-verified

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,

Callers 5

set_finished_stateMethod · 0.80
set_failed_stateMethod · 0.80
set_cancel_stateMethod · 0.80
abort_tasksMethod · 0.80
handle_job_closeFunction · 0.80

Calls 4

has_no_active_tasksMethod · 0.80
on_job_idleMethod · 0.80
on_job_completedMethod · 0.80
is_openMethod · 0.45

Tested by

no test coverage detected