fix: reformatted

cmeesters · cmeesters · commit 14c46aa14eec · 2025-03-12T17:42:29.000+01:00
diff --git a/snakemake_executor_plugin_slurm/__init__.py b/snakemake_executor_plugin_slurm/__init__.py
@@ -575,7 +575,7 @@ async def job_stati(self, command):
                         f"Waiting {interval} seconds before retrying..."
                     )
                     await asyncio.sleep(interval)
-                    
+
                     try:
                         time_before_query = time.time()
                         command_res = subprocess.check_output(
@@ -589,7 +589,9 @@ async def job_stati(self, command):
                         )
                         res = {
                             entry[0]: entry[1].split(sep=None, maxsplit=1)[0]
-                            for entry in csv.reader(StringIO(command_res), delimiter="|")
+                            for entry in csv.reader(
+                                StringIO(command_res), delimiter="|"
+                            )
                         }
                         return (res, query_duration)  # Success, exit retry loop
                     except subprocess.CalledProcessError as e:

Original file line number	Diff line number	Diff line change
`@@ -575,7 +575,7 @@ async def job_stati(self, command):`
`575`	`575`	`f"Waiting {interval} seconds before retrying..."`
`576`	`576`	`)`
`577`	`577`	`await asyncio.sleep(interval)`
`578`		`-`
	`578`	`+`
`579`	`579`	`try:`
`580`	`580`	`time_before_query = time.time()`
`581`	`581`	`command_res = subprocess.check_output(`
`@@ -589,7 +589,9 @@ async def job_stati(self, command):`
`589`	`589`	`)`
`590`	`590`	`res = {`
`591`	`591`	`entry[0]: entry[1].split(sep=None, maxsplit=1)[0]`
`592`		`- for entry in csv.reader(StringIO(command_res), delimiter="\|")`
	`592`	`+ for entry in csv.reader(`
	`593`	`+ StringIO(command_res), delimiter="\|"`
	`594`	`+ )`
`593`	`595`	`}`
`594`	`596`	`return (res, query_duration) # Success, exit retry loop`
`595`	`597`	`except subprocess.CalledProcessError as e:`