Propper formatting

ChristofferRS · ChristofferRS · commit c9327dce6edf · 2025-06-01T15:32:25.000+02:00
diff --git a/src/snakemake/dag.py b/src/snakemake/dag.py
@@ -961,10 +961,16 @@ def unneeded_files():
 
         for f in unneeded_files():
             if self.workflow.dryrun:
-                if not self.workflow.output_settings.quiet or Quietness.RULES not in self.workflow.output_settings.quiet:
+                if (
+                    not self.workflow.output_settings.quiet
+                    or Quietness.RULES not in self.workflow.output_settings.quiet
+                ):
                     logger.info(f"Would remove temporary output {fmt_iofile(f)}")
             else:
-                if not self.workflow.output_settings.quiet or Quietness.RULES not in self.workflow.output_settings.quiet:
+                if (
+                    not self.workflow.output_settings.quiet
+                    or Quietness.RULES not in self.workflow.output_settings.quiet
+                ):
                     logger.info(f"Removing temporary output {fmt_iofile(f)}.")
                 await f.remove(remove_non_empty_dir=True)
 
diff --git a/src/snakemake/logging.py b/src/snakemake/logging.py
@@ -506,7 +506,7 @@ def emit(self, record):
                     # Reset flag if the message is not a 'job_info'
                     self.last_msg_was_job_info = False
                 formatted_message = self.format(record)
-                if formatted_message == "None" or formatted_message=="":
+                if formatted_message == "None" or formatted_message == "":
                     return
                 # Apply color to the formatted message
                 self.stream.write(self.decorate(record, formatted_message))
diff --git a/src/snakemake/scheduler.py b/src/snakemake/scheduler.py
@@ -70,7 +70,9 @@ def __init__(self, workflow, executor_plugin: ExecutorPlugin):
         self._toerror = []
         self.handle_job_success = True
         self.update_resources = True
-        self.print_progress = (not self.quiet or Quietness.PROGRESS not in self.quiet) and not self.dryrun
+        self.print_progress = (
+            not self.quiet or Quietness.PROGRESS not in self.quiet
+        ) and not self.dryrun
         self.update_checkpoint_dependencies = not self.dryrun
         self.job_rate_limiter = (
             JobRateLimiter(self.workflow.scheduling_settings.max_jobs_per_timespan)
