change sign

WIPACrepo · Jan 21, 2025 · 8782fed · 8782fed
1 parent 3c5118c
commit 8782fed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/iceprod/materialization/materialize.py b/iceprod/materialization/materialize.py
@@ -65,7 +65,7 @@ async def run_once(self, only_dataset=None, set_status=None, num=10000, dryrun=F
                     logger.info('num_tasks: %d', num_tasks)
                     logger.info('tasks_per_job: %d', dataset['tasks_per_job'])
                     for job_tmp_index in range(job_index-1, -1, -1):
-                        if job_index * dataset['tasks_per_job'] >= num_tasks:
+                        if job_index * dataset['tasks_per_job'] <= num_tasks:
                             break
                         logger.info('a job must have failed to buffer, so check in reverse order. job_index=%d, num_tasks=%d', job_tmp_index, num_tasks)
                         job_tasks = await self.rest_client.request('GET', f'/datasets/{dataset_id}/tasks',