mirror of
https://github.com/ansible/awx.git
synced 2026-02-15 10:10:01 -03:30
Remove spurious workflow job class
This commit is contained in:
@@ -1739,38 +1739,3 @@ class RunSystemJob(BaseTask):
|
|||||||
|
|
||||||
def build_cwd(self, instance, **kwargs):
|
def build_cwd(self, instance, **kwargs):
|
||||||
return settings.BASE_DIR
|
return settings.BASE_DIR
|
||||||
|
|
||||||
'''
|
|
||||||
class RunWorkflowJob(BaseTask):
|
|
||||||
|
|
||||||
name = 'awx.main.tasks.run_workflow_job'
|
|
||||||
model = WorkflowJob
|
|
||||||
|
|
||||||
def run(self, pk, **kwargs):
|
|
||||||
#Run the job/task and capture its output.
|
|
||||||
instance = self.update_model(pk, status='running', celery_task_id=self.request.id)
|
|
||||||
instance.websocket_emit_status("running")
|
|
||||||
|
|
||||||
# FIXME: Currently, the workflow job busy waits until the graph run is
|
|
||||||
# complete. Instead, the workflow job should return or never even run,
|
|
||||||
# because all of the "launch logic" can be done schedule().
|
|
||||||
|
|
||||||
# However, other aspects of our system depend on a 1-1 relationship
|
|
||||||
# between a Job and a Celery Task.
|
|
||||||
#
|
|
||||||
# * If we let the workflow job task (RunWorkflowJob.run()) complete
|
|
||||||
# then how do we trigger the handle_work_error and
|
|
||||||
# handle_work_success subtasks?
|
|
||||||
#
|
|
||||||
# * How do we handle the recovery process? (i.e. there is an entry in
|
|
||||||
# the database but not in celery).
|
|
||||||
while True:
|
|
||||||
dag = WorkflowDAG(instance)
|
|
||||||
if dag.is_workflow_done():
|
|
||||||
# TODO: update with accurate finish status (i.e. canceled, error, etc.)
|
|
||||||
instance = self.update_model(instance.pk, status='successful')
|
|
||||||
break
|
|
||||||
time.sleep(1)
|
|
||||||
instance.websocket_emit_status(instance.status)
|
|
||||||
# TODO: Handle cancel
|
|
||||||
'''
|
|
||||||
|
|||||||
Reference in New Issue
Block a user