Fix the config task

This commit is contained in:
Nico Schottelius 2020-12-20 19:17:03 +01:00
commit 689375a2fe
2 changed files with 10 additions and 5 deletions

View file

@ -3,11 +3,16 @@ from celery.result import AsyncResult
from .models import UncloudTask
@shared_task
def cleanup_tasks():
print("Cleanup time")
@shared_task(bind=True)
def cleanup_tasks(self):
print(f"Cleanup time from {self}: {self.request.id}")
for task in UncloudTask.objects.all():
print(f"Pruning {task}...")
if str(task.task_id) == str(self.request.id):
print("Skipping myself")
continue
res = AsyncResult(id=str(task.task_id))
if res.ready():
print(res.get())