Commit dcd0a845 authored by David Mendez's avatar David Mendez
Browse files

Summon status check meeseeks after launching job

parent 9e791ff3
......@@ -560,6 +560,12 @@ def submit_job_to_lsf(job):
delayed_job_models.save_job(job)
app_logging.debug(f'LSF Job ID is: {lsf_job_id}')
app_logging.debug('Going to launch Mr Meeseeks to monitor the job status')
meeseeks_command = f'CONFIG_FILE_PATH={os.getenv("CONFIG_FILE_PATH")} /app/run_daemon.sh {job.id}'
app_logging.debug('Mr Meeseeks command is: {meeseeks_command}')
meeseeks_process = subprocess.Popen(meeseeks_command.split(' '))
app_logging.debug(f'Mr Meeseeks summoned! PID is {meeseeks_process.pid}')
def get_lsf_job_id(submission_out):
"""
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment