fix: clean up whitespace and improve code formatting across multiple files

Author: legout

src/flowerpower/job_queue/base.py

@@ -23,6 +23,7 @@
 
 from ..cfg import ProjectConfig
 from ..fs import AbstractFileSystem, get_filesystem
+
 # from ..utils.misc import update_config_from_dict
 from ..settings import BACKEND_PROPERTIES
 

src/flowerpower/pipeline/io.py

@@ -7,19 +7,19 @@
 
 import posixpath
 
+from loguru import logger
 from rich.console import Console
 
 # Import necessary config types and utility functions
 from ..fs.base import (
     AbstractFileSystem,
     BaseStorageOptions,
-    get_filesystem,
     DirFileSystem,
+    get_filesystem,
 )
-from .registry import PipelineRegistry
-from loguru import logger
 from ..settings import LOG_LEVEL
 from ..utils.logging import setup_logging
+from .registry import PipelineRegistry
 
 console = Console()
 
@@ -103,7 +103,7 @@ def _get_filesystem(base_dir, fs, storage_options):
         #     raise NotImplementedError(
         #         f"The destination filesystem {dest_fs }does not support get_mapper."
         #     )
-       
+
         if files is None:
             files = src_fs.glob("**/*.py")
             files.extend(src_fs.glob("**/*.yml"))
@@ -123,11 +123,10 @@ def _get_filesystem(base_dir, fs, storage_options):
                     logger.warning(
                         f"File {file} already exists in the destination. Skipping write. Use overwrite=True to overwrite."
                     )
-                    continue            
-            
+                    continue
+
             content = src_fs.read_bytes(file)
             dest_fs.write_bytes(file, content)
-           
 
     def import_pipeline(
         self,
@@ -419,7 +418,7 @@ def export_all(
             # pm.export_all("s3://my-bucket/pipelines_backup", storage_options={"key": "...", "secret": "..."}, overwrite=False)
             ```
         """
-        #sync the filesystem
+        # sync the filesystem
         self._sync_filesystem(
             src_base_dir=".",
             src_fs=self._fs,
@@ -432,4 +431,4 @@ def export_all(
         )
         console.print(
             f"✅ Exported all pipelines from [bold blue]{self.project_cfg.name}[/bold blue] to [green]{dest_base_dir}[/green]"
-        )
+        )

src/flowerpower/pipeline/job_queue.py

@@ -11,6 +11,7 @@
 from rich import print as rprint
 
 from .. import settings
+
 # Import necessary config types
 from ..cfg import PipelineConfig, ProjectConfig
 from ..fs import AbstractFileSystem

src/flowerpower/pipeline/manager.py

@@ -835,7 +835,7 @@ def import_many(
             storage_options (dict | BaseStorageOptions | None, optional): Options for source filesystem access
                 Example: {"key": "ACCESS_KEY", "secret": "SECRET_KEY"}
             overwrite (bool, optional): Whether to replace existing pipelines
-            
+
         Raises:
             ValueError: If any pipeline exists and overwrite=False
             FileNotFoundError: If source pipelines not found

src/flowerpower/plugins/mqtt/manager.py

@@ -284,7 +284,7 @@ def run_in_background(
         Returns:
             None
 
-            
+
         """
         if self._client is None or not self._client.is_connected():
             self.connect()