Skip to content

Commit

Permalink
Use generator comprehension, and fix formatting.
Browse files Browse the repository at this point in the history
  • Loading branch information
robertbartel committed May 29, 2024
1 parent 9599d97 commit 7789a8f
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -486,7 +486,8 @@ async def manage_job_partitioning(self):
while not self._job_util.lock_active_jobs(lock_id):
await asyncio.sleep(2)

for job in [j for j in self._job_util.get_all_active_jobs() if j.status_step == JobExecStep.AWAITING_PARTITIONING]:
for job in (j for j in self._job_util.get_all_active_jobs() if
j.status_step == JobExecStep.AWAITING_PARTITIONING):
partition_requirements = [r for r in job.data_requirements if
r.domain.data_format == DataFormat.NGEN_PARTITION_CONFIG]
assert len(partition_requirements) <= 1
Expand Down

0 comments on commit 7789a8f

Please sign in to comment.