ExternalVendorCode/onefuzz
1
0
Fork 0
mirror of https://github.com/microsoft/onefuzz.git synced 2025-06-13 10:38:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

mark tasks that are stopped that never started with an error (#935)

Browse Source
This commit is contained in:
bmc-msft
2021-05-26 18:42:21 -04:00
committed by GitHub
parent 87eb8ac80a
commit d557fc16c6
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/api-service/__app__/onefuzzlib/tasks/main.py
View File

@ -195,6 +195,11 @@ class Task(BASE_TASK, ORMMixin):
) )
return return
if self.state not in TaskState.has_started():
self.mark_failed(
Error(code=ErrorCode.TASK_FAILED, errors=["task never started"])
)
self.set_state(TaskState.stopping) self.set_state(TaskState.stopping)
def mark_failed( def mark_failed(

2
src/api-service/__app__/timer_tasks/__init__.py
View File

@ -19,7 +19,7 @@ def main(mytimer: func.TimerRequest, dashboard: func.Out[str]) -> None: # noqa:
expired_tasks = Task.search_expired() expired_tasks = Task.search_expired()
for task in expired_tasks: for task in expired_tasks:
logging.info("stopping expired task: %s", task.job_id) logging.info("stopping expired task: %s", task.job_id)
task.stopping() task.mark_stopping()
expired_jobs = Job.search_expired() expired_jobs = Job.search_expired()
for job in expired_jobs: for job in expired_jobs: