diff --git a/rnaseq_pipeline/tasks.py b/rnaseq_pipeline/tasks.py index 57f0e6db..af88d939 100755 --- a/rnaseq_pipeline/tasks.py +++ b/rnaseq_pipeline/tasks.py @@ -489,7 +489,7 @@ class SubmitExperimentsFromDataFrameMixin: def requires(self): df = self._retrieve_dataframe() # using None, the worker will inherit the priority from this task for all its dependencies - return [SubmitExperimentToGemma(row.experiment_id, priority=100 if self.ignore_priority else row.get('priority'), rerun=row.get('data')=='resubmit') + return [SubmitExperimentToGemma(row.experiment_id, priority=100 if self.ignore_priority else row.get('priority', 100), rerun=row.get('data')=='resubmit') for _, row in df.iterrows() if row.get('priority', 1) > 0] class SubmitExperimentsFromFileToGemma(SubmitExperimentsFromDataFrameMixin, TaskWithOutputMixin, WrapperTask):