fix: ensure correct topological order when touching group job outputs (…

…#3181) fixes #3165 ### QC  * [ ] The PR contains a test case for the changes or the changes are already covered by an existing test case. * [ ] The documentation (`docs/`) is updated to reflect the changes or this is not necessary (e.g. if the change does neither modify the language nor the behavior or functionalities of Snakemake).  ## Summary by CodeRabbit - **Bug Fixes** - Improved management of asynchronous tasks in job processing, enhancing performance and reliability. - Updated output verification process for jobs to ensure protected outputs are correctly checked. - **Refactor** - Reorganized task creation logic to streamline job processing.
snakemake · Nov 1, 2024 · 5924a3e · 5924a3e
1 parent 14214bb
commit 5924a3e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/snakemake/jobs.py b/snakemake/jobs.py
@@ -1514,8  1514,8 @@ async def cleanup(self):
     async def postprocess(self, error=False, **kwargs):
         # Iterate over jobs in toposorted order (see self.__iter__) to
         # ensure that outputs are touched in correct order.
-        async with asyncio.TaskGroup() as tg:
-            for level in self.toposorted:
         for level in self.toposorted:
             async with asyncio.TaskGroup() as tg:
                 for job in level:
                     # postprocessing involves touching output files (to ensure that
                     # modification times are always correct. This has to happen in