From e4e9a7270451853bc122a6dfb72d8adb071c7617 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 17 Feb 2025 17:05:44 +0000 Subject: [PATCH 1/2] [pre-commit.ci] pre-commit autoupdate MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit updates: - [github.com/pre-commit/pre-commit-hooks: v4.4.0 → v5.0.0](https://github.com/pre-commit/pre-commit-hooks/compare/v4.4.0...v5.0.0) - [github.com/psf/black: 23.7.0 → 25.1.0](https://github.com/psf/black/compare/23.7.0...25.1.0) - [github.com/PyCQA/flake8: 6.1.0 → 7.1.2](https://github.com/PyCQA/flake8/compare/6.1.0...7.1.2) --- .pre-commit-config.yaml | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 From 9a73a1ef6b3918ccd4c0fad7b5eea3154031a612 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 17 Feb 2025 17:05:55 +0000 Subject: [PATCH 2/2] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- datacube_alchemist/_dask.py | 5 +++-- datacube_alchemist/worker.py | 12 ++++++------ 2 files changed, 9 insertions(+), 8 deletions(-) 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():