From 937143ce0f7d349d8b314e3a509115845d25f5fd Mon Sep 17 00:00:00 2001 From: Tom Galindo <98626996+thommodin@users.noreply.github.com> Date: Fri, 3 Jul 2026 12:58:20 +1000 Subject: [PATCH] lint 0 --- src/data_index/runners/index.py | 2 -- src/data_index/transform.py | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/src/data_index/runners/index.py b/src/data_index/runners/index.py index 9c99185..6a01b80 100644 --- a/src/data_index/runners/index.py +++ b/src/data_index/runners/index.py @@ -152,7 +152,6 @@ def index_batch( logger.info(f"Batch {i} had dead letters!") prefect.states.raise_state_exception(state=state) - # Fail for unknown reason, assume dead letter sinking failed case state: error = ( @@ -170,7 +169,6 @@ def index_batch( dead_letter_sink=dead_letter_sink, ) prefect.states.raise_state_exception(state=state) - @prefect.flow diff --git a/src/data_index/transform.py b/src/data_index/transform.py index 2c7d8c3..1b09ae4 100644 --- a/src/data_index/transform.py +++ b/src/data_index/transform.py @@ -168,7 +168,7 @@ def transform( # Fallback/Catch-all case (e.g., if max_workers is 0, negative, or an invalid type) case _: raise ValueError(f"Invalid value for max_workers: {max_workers}") - + logger.info(f"Extracted {len(staged_objects)} staged_objects!") logger.info("Transform complete!")