diff --git a/datacube_alchemist/_dask.py b/datacube_alchemist/_dask.py
index c1bcdac..43edd9f 100644
--- 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
index 5dd9e9c..2b4df05 100644
--- 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():