feat: 修复 JOB 定时任务不执行的问题

apps/ops/api/job.py

@@ -72,7 +72,7 @@ class JobExecutionViewSet(OrgBulkModelViewSet):
         instance = serializer.save()
         instance.job_version = instance.job.version
         instance.material = instance.job.material
-        instance.type = Types[instance.job.type].value
+        instance.job_type = Types[instance.job.type].value
         instance.creator = self.request.user
         instance.save()
         task = run_ops_job_execution.delay(instance.id)

apps/ops/models/job.py

@@ -73,9 +73,9 @@ class Job(JMSOrgBaseModel, PeriodTaskModelMixin):
         return total_cost / finished_count if finished_count else 0
 
     def get_register_task(self):
-        from ..tasks import run_ops_job_execution
+        from ..tasks import run_ops_job
         name = "run_ops_job_period_{}".format(str(self.id)[:8])
-        task = run_ops_job_execution.name
+        task = run_ops_job.name
         args = (str(self.id),)
         kwargs = {}
         return name, task, args, kwargs

apps/ops/tasks.py

@@ -27,17 +27,18 @@ logger = get_logger(__file__)
 @shared_task(soft_time_limit=60, queue="ansible", verbose_name=_("Run ansible task"))
 def run_ops_job(job_id):
     job = get_object_or_none(Job, id=job_id)
-    execution = job.create_execution()
-    run_ops_job_execution(execution)
-
-
-#
-# @shared_task(soft_time_limit=60, queue="ansible")
-# def show_env():
-#     import json
-#     print(os.environ)
-#     data = json.dumps(dict(os.environ), indent=4)
-#     return data
+    with tmp_to_org(job.org):
+        execution = job.create_execution()
+        execution.creator = job.creator
+        run_ops_job_execution(execution.id)
+        try:
+            execution.start()
+        except SoftTimeLimitExceeded:
+            execution.set_error('Run timeout')
+            logger.error("Run adhoc timeout")
+        except Exception as e:
+            execution.set_error(e)
+            logger.error("Start adhoc execution error: {}".format(e))
 
 
 @shared_task(soft_time_limit=60, queue="ansible", verbose_name=_("Run ansible task execution"))