Skip to content

Commit

Permalink
(pass log name, but it is probably dysfunctional there)
Browse files Browse the repository at this point in the history
  • Loading branch information
eudoxos committed May 21, 2024
1 parent 59f148b commit 81d6c46
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions mupifDB/workflowscheduler.py
Original file line number Diff line number Diff line change
Expand Up @@ -371,7 +371,7 @@ def executeWorkflow_inner2(lock, schedulerState, we_id: str, we_rec, workflow_re
workflowLogName = tempDir+'/workflow.log'
execScript = Path(tempDir+'/workflow_execution_script.py')
# copy workflow source to tempDir
if not executeWorkflow_copyInputs(we_id,workflow_record,tempDir,execScript):
if not executeWorkflow_copyInputs(we_id,workflow_record,tempDir,execScript,workflowLogName):
return we_id, ExecutionResult.Failed
# execute
log.info("Executing we_id %s, tempdir %s" % (we_id, tempDir))
Expand Down Expand Up @@ -439,7 +439,7 @@ def executeWorkflow_inner2(lock, schedulerState, we_id: str, we_rec, workflow_re
pass


def executeWorkflow_copyInputs(we_id,workflow_record,tempDir,execScript) -> bool:
def executeWorkflow_copyInputs(we_id,workflow_record,tempDir,execScript,workflowLogName) -> bool:
try:
python_script_filename = workflow_record['modulename'] + ".py"

Expand Down Expand Up @@ -480,6 +480,7 @@ def executeWorkflow_copyInputs(we_id,workflow_record,tempDir,execScript) -> bool
restApiControl.setExecutionStatusFailed(we_id)
my_email.sendEmailAboutExecutionStatus(we_id)
try:
# XXX: there is no log yet, what is this support to copy??
copyLogToDB(we_id, workflowLogName)
except:
log.info("Copying log files was not successful")
Expand Down

0 comments on commit 81d6c46

Please sign in to comment.