diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index cdd28f6..7f071c5 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -1,6 +1,6 @@ repos: - repo: https://github.com/pre-commit/pre-commit-hooks - rev: v4.4.0 + rev: v5.0.0 hooks: - id: trailing-whitespace - id: end-of-file-fixer @@ -18,7 +18,7 @@ repos: # hooks: # - id: yamllint - repo: https://github.com/psf/black - rev: 23.7.0 + rev: 25.1.0 hooks: - id: black - repo: https://github.com/pre-commit/mirrors-pylint @@ -26,6 +26,6 @@ repos: hooks: - id: pylint - repo: https://github.com/PyCQA/flake8 - rev: 6.1.0 + rev: 7.1.2 hooks: - id: flake8 diff --git a/datacube_alchemist/_dask.py b/datacube_alchemist/_dask.py index c1bcdac..e7a5825 100644 --- a/datacube_alchemist/_dask.py +++ b/datacube_alchemist/_dask.py @@ -1,6 +1,7 @@ -""" Dask Distributed Tools - - dask_compute_stream +"""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():