stop jobs once all tasks are stopped

src/api-service/__app__/onefuzzlib/jobs.py

@@ -85,6 +85,20 @@ def init(self) -> None:
         self.state = JobState.enabled
         self.save()
 
+    def stop_if_all_done(self) -> None:
+        not_stopped = [
+            task
+            for task in Task.search(query={"job_id": [self.job_id]})
+            if task.state != TaskState.stopped
+        ]
+        if not_stopped:
+            return
+
+        logging.info(
+            JOB_LOG_PREFIX + "stopping job as all tasks are stopped: %s", self.job_id
+        )
+        self.stopping()
+
     def stopping(self) -> None:
         self.state = JobState.stopping
         logging.info(JOB_LOG_PREFIX + "stopping: %s", self.job_id)

src/api-service/__app__/onefuzzlib/tasks/main.py

@@ -126,13 +126,18 @@ def init(self) -> None:
 
     def stopping(self) -> None:
         # TODO: we need to 'unschedule' this task from the existing pools
+        from ..jobs import Job
 
         logging.info("stopping task: %s:%s", self.job_id, self.task_id)
         ProxyForward.remove_forward(self.task_id)
         delete_queue(str(self.task_id), StorageType.corpus)
         Node.stop_task(self.task_id)
         self.set_state(TaskState.stopped, send=False)
 
+        job = Job.get(self.job_id)
+        if job:
+            job.stop_if_all_done()
+
     @classmethod
     def search_states(
         cls, *, job_id: Optional[UUID] = None, states: Optional[List[TaskState]] = None