diff --git a/apps/ops/models/adhoc.py b/apps/ops/models/adhoc.py index 9668819b9..d5cf7c3fc 100644 --- a/apps/ops/models/adhoc.py +++ b/apps/ops/models/adhoc.py @@ -14,6 +14,7 @@ from django.utils.translation import ugettext_lazy as _ from django_celery_beat.models import PeriodicTask from common.utils import get_signer, get_logger +from orgs.utils import set_to_root_org from ..celery.utils import delete_celery_periodic_task, \ create_or_update_celery_periodic_tasks, \ disable_celery_periodic_task @@ -83,6 +84,7 @@ class Task(models.Model): return self.history.all() def run(self, record=True): + set_to_root_org() if self.latest_adhoc: return self.latest_adhoc.run(record=record) else: