Une MAJ de sécurité est nécessaire sur notre version actuelle. Elle sera effectuée lundi 02/08 entre 12h30 et 13h. L'interruption de service devrait durer quelques minutes (probablement moins de 5 minutes).

Commit 97cd77f1 authored by Ryan Herbert's avatar Ryan Herbert Committed by Mikaël Salson
Browse files

file.py task.py use COMPLETED for pre_process_flag

it matches what the scheduler would use. But we still need to check for
"DONE" since it currently exists in the database.
parent df4c438f
Pipeline #35114 passed with stages
in 22 seconds
......@@ -201,7 +201,7 @@ def submit():
error = False
pre_process = None
pre_process_flag = "DONE"
pre_process_flag = "COMPLETED"
if 'pre_process' in data and data['pre_process'] is not None and\
int(data['pre_process']) > 0:
pre_process = int(data['pre_process'])
......@@ -117,7 +117,7 @@ def schedule_run(id_sequence, id_config, grep_reads=None):
task = scheduler.queue_task(program, args,
repeats = 1, timeout = defs.TASK_TIMEOUT)
if db.sequence_file[id_sequence].pre_process_flag != "DONE" and db.sequence_file[id_sequence].pre_process_flag :
if db.sequence_file[id_sequence].pre_process_flag not in ["COMPLETED", "DONE"] and db.sequence_file[id_sequence].pre_process_flag :
db.scheduler_task[task.id] = dict(status ="STOPPED")
db.results_file[data_id] = dict(scheduler_task_id = task.id)
......@@ -842,7 +842,7 @@ def run_pre_process(pre_process_id, sequence_file_id, clean_before=True, clean_a
# We forget the initial data_file (and possibly data_file2)
db.sequence_file[sequence_file_id] = dict(data_file = stream,
data_file2 = None,
pre_process_flag = "DONE")
pre_process_flag = "COMPLETED")
#resume STOPPED task for this sequence file
stopped_task = db(
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