refactor: improve code readability by adjusting line breaks and formatting

Author: LeoLee-Xiaohu

aodn_cloud_optimised/lib/CommonHandler.py

@@ -120,9 +120,9 @@ def __init__(self, **kwargs):
 
         self.scheduler = kwargs.get("scheduler", None)
         if self.scheduler is None:
-            self.coiled_cluster_options = self.dataset_config.get("run_settings", {}).get(
-                "coiled_cluster_options", None
-            )
+            self.coiled_cluster_options = self.dataset_config.get(
+                "run_settings", {}
+            ).get("coiled_cluster_options", None)
 
             self.cluster_manager = ClusterManager(
                 cluster_mode=self.cluster_mode,

aodn_cloud_optimised/lib/GenericParquetHandler.py

@@ -1653,7 +1653,7 @@ def task(f, i):
             ii += 1
 
             # Cleanup memory
-            if 'batch_tasks' in locals():
+            if "batch_tasks" in locals():
                 del batch_tasks
 
             # Trigger garbage collection

aodn_cloud_optimised/lib/GenericZarrHandler.py

@@ -17,8 +17,8 @@
 from distributed.client import FutureCancelledError
 from distributed.scheduler import KilledWorker
 from distributed.shuffle._exceptions import P2PConsistencyError
-from xarray.coding.times import CFDatetimeCoder
 from xarray import MergeError
+from xarray.coding.times import CFDatetimeCoder
 
 from aodn_cloud_optimised.lib.CommonHandler import CommonHandler
 from aodn_cloud_optimised.lib.logging import get_logger
@@ -1083,7 +1083,9 @@ def publish_cloud_optimised_fileset_batch(self, s3_file_uri_list):
             if attrs.get("drop_var", False)
         ]
 
-        partial_preprocess = partial(preprocess_xarray, dataset_config=self.dataset_config)
+        partial_preprocess = partial(
+            preprocess_xarray, dataset_config=self.dataset_config
+        )
 
         if self.cluster_mode:
             batch_size = self.get_batch_size(client=self.client)
@@ -1800,12 +1802,14 @@ def handle_append_dim_overlap(
                 batch_files,
                 dim_name=dim_name,
                 dataset_config=self.dataset_config,
-                uuid_log=self.uuid_log
+                uuid_log=self.uuid_log,
             )
             ranges = self.client.gather(futures)
         else:
             ranges = [
-                check_append_dim_range_dask(f, dim_name, self.dataset_config, self.uuid_log)
+                check_append_dim_range_dask(
+                    f, dim_name, self.dataset_config, self.uuid_log
+                )
                 for f in batch_files
             ]
 
@@ -1957,7 +1961,7 @@ def check_variable_values_parallel(self, file_paths, variable_name):
                 reference_values=reference_values,
                 variable_name=variable_name,
                 dataset_config=self.dataset_config,
-                uuid_log=self.uuid_log
+                uuid_log=self.uuid_log,
             )
             results = self.client.gather(futures)
         else:
@@ -1972,7 +1976,7 @@ def check_variable_values_parallel(self, file_paths, variable_name):
                     reference_values,
                     variable_name,
                     self.dataset_config,
-                    self.uuid_log
+                    self.uuid_log,
                 )
                 for file_path in file_paths[1:]
             ]