diff --git a/sql/archiver.py b/sql/archiver.py index 9bc5cf11cd..d04ea7f5bf 100644 --- a/sql/archiver.py +++ b/sql/archiver.py @@ -535,5 +535,5 @@ def archive_switch(request): def archive_once(request): """单次立即调用归档任务""" archive_id = request.GET.get("archive_id") - archive.apply_async(archive_id) # 使用 Celery 的apply_async方法调度任务 + archive.apply_async(args=[archive_id]) # 使用 Celery 的apply_async方法调度任务 return JsonResponse({"status": 0, "msg": "ok", "data": {}}) diff --git a/sql/utils/tasks.py b/sql/utils/tasks.py index 15de20f7fb..5b271994f2 100644 --- a/sql/utils/tasks.py +++ b/sql/utils/tasks.py @@ -58,7 +58,10 @@ def del_schedule(name): def task_info(name): - """获取定时任务详情""" + """ + 获取定时任务详情 + 如果未使用celery beat实现的定时任务,这里无法获取到对应的结果,只会返回一个None + """ try: periodic_task = PeriodicTask.objects.get(name=name) return periodic_task