diff --git a/nodestream/pipeline/extractors/stores/aws/s3_extractor.py b/nodestream/pipeline/extractors/stores/aws/s3_extractor.py index 293ac6cd..0aa87b5c 100644 --- a/nodestream/pipeline/extractors/stores/aws/s3_extractor.py +++ b/nodestream/pipeline/extractors/stores/aws/s3_extractor.py @@ -27,7 +27,7 @@ def __init__( def archive_if_required(self, key: str): if not self.archive_dir: - pass + return LOGGER.info("Archiving S3 Object", extra=dict(key=key)) filename = Path(key).name diff --git a/pyproject.toml b/pyproject.toml index a8680b8d..6c52bc00 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "nodestream" -version = "0.12.5a13" +version = "0.12.5a14" description = "A Fast, Declarative ETL for Graph Databases." license = "GPL-3.0-only" authors = [