(self, session)
| 1013 | session.add(self) |
| 1014 | |
| 1015 | def refresh_stat_count_tasks(self, session): |
| 1016 | task_count_available = Task.list( |
| 1017 | session, |
| 1018 | status = 'available', |
| 1019 | job_id = self.id, |
| 1020 | project_id = self.project_id, |
| 1021 | return_mode = "count" |
| 1022 | ) |
| 1023 | task_in_progress = Task.list( |
| 1024 | session, |
| 1025 | status = 'in_progress', |
| 1026 | job_id = self.id, |
| 1027 | project_id = self.project_id, |
| 1028 | return_mode = "count" |
| 1029 | ) |
| 1030 | task_count_complete = Task.list( |
| 1031 | session, |
| 1032 | status = 'complete', |
| 1033 | job_id = self.id, |
| 1034 | project_id = self.project_id, |
| 1035 | return_mode = "count" |
| 1036 | ) |
| 1037 | |
| 1038 | self.stat_count_tasks = task_count_complete + task_count_available + task_in_progress |
| 1039 | self.stat_count_complete = task_count_complete |
| 1040 | session.add(self) |
| 1041 | return |
| 1042 | |
| 1043 | def update_job_status( |
| 1044 | self, |
no test coverage detected