[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci
opendatacube · Apr 8, 2024 · ff84137 · ff84137
1 parent 065a80c
commit ff84137
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/datacube_alchemist/_dask.py b/datacube_alchemist/_dask.py
@@ -1,6 +1,7 @@
 """ Dask Distributed Tools
    - dask_compute_stream
 """
+
 import queue
 import threading
 from random import randint

diff --git a/datacube_alchemist/worker.py b/datacube_alchemist/worker.py
@@ -345,9 +345,9 @@ def _determine_output_product(self):
                 setattr(dataset_assembler, k, v)
             # add dataset maturity property from original dataset rather than output config
             if "dea:dataset_maturity" in source_doc.properties:
-                dataset_assembler.properties[
-                    "dea:dataset_maturity"
-                ] = source_doc.properties["dea:dataset_maturity"]
+                dataset_assembler.properties["dea:dataset_maturity"] = (
+                    source_doc.properties["dea:dataset_maturity"]
+                )
             if self.config.output.properties:
                 for k, v in self.config.output.properties.items():
                     dataset_assembler.properties[k] = v
@@ -478,9 +478,9 @@ def execute_task(
                     )
                     # also extract dataset maturity
                     if "dea:dataset_maturity" in source_doc.properties:
-                        dataset_assembler.properties[
-                            "dea:dataset_maturity"
-                        ] = source_doc.properties["dea:dataset_maturity"]
+                        dataset_assembler.properties["dea:dataset_maturity"] = (
+                            source_doc.properties["dea:dataset_maturity"]
+                        )
 
                 # Copy in metadata and properties
                 for k, v in task.settings.output.metadata.items():