diff --git a/gso/workflows/tasks/clean_old_tasks.py b/gso/workflows/tasks/clean_old_tasks.py index cdc9a0decf57fda5de80b3ad14092ad326d4a054..13563459262da03f8089d54523da50503cfdf035 100644 --- a/gso/workflows/tasks/clean_old_tasks.py +++ b/gso/workflows/tasks/clean_old_tasks.py @@ -7,8 +7,8 @@ from orchestrator.workflow import StepList, begin, done, step, workflow from gso.services.processes import get_all_cleanup_tasks, get_created_and_completed_processes_by_id -@step("Clean up all cleanup tasks") -def remove_meta_tasks() -> None: +@step("Remove old cleanup tasks") +def remove_old_cleanup_tasks() -> None: """Find and remove runs of old cleanup tasks.""" cleanup_tasks = get_all_cleanup_tasks() @@ -27,4 +27,4 @@ def task_clean_old_tasks() -> StepList: task. Once they have run to completion, or are stuck in a "created" state, they serve no purpose in the database and can therefore be removed. """ - return begin >> remove_meta_tasks >> done + return begin >> remove_old_cleanup_tasks >> done