This is an automated email from the ASF dual-hosted git repository. rkk pushed a commit to branch SDAP-512 in repository https://gitbox.apache.org/repos/asf/incubator-sdap-ingester.git
commit 30d5b1d6f890963025960087c863424079c660fd Author: rileykk <[email protected]> AuthorDate: Wed Mar 6 10:22:36 2024 -0800 Try just using destructor instead of explicit close() calls --- granule_ingester/granule_ingester/pipeline/Pipeline.py | 9 +++++---- granule_ingester/granule_ingester/writers/MetadataStore.py | 3 +++ 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/granule_ingester/granule_ingester/pipeline/Pipeline.py b/granule_ingester/granule_ingester/pipeline/Pipeline.py index 541700f..662aa46 100644 --- a/granule_ingester/granule_ingester/pipeline/Pipeline.py +++ b/granule_ingester/granule_ingester/pipeline/Pipeline.py @@ -257,11 +257,12 @@ class Pipeline: logger.info(f"Now writing generated tiles...") await self._data_store_factory().save_batch(results) + await self._metadata_store_factory().save_batch(results) - metadata_store = self._metadata_store_factory() - await metadata_store.save_batch(results) - - metadata_store.close() + # metadata_store = self._metadata_store_factory() + # await metadata_store.save_batch(results) + # + # metadata_store.close() end = time.perf_counter() logger.info("Pipeline finished in {} seconds".format(end - start)) diff --git a/granule_ingester/granule_ingester/writers/MetadataStore.py b/granule_ingester/granule_ingester/writers/MetadataStore.py index 7296075..e1e317b 100644 --- a/granule_ingester/granule_ingester/writers/MetadataStore.py +++ b/granule_ingester/granule_ingester/writers/MetadataStore.py @@ -41,3 +41,6 @@ class MetadataStore(HealthCheck, ABC): def close(self) -> None: pass + def __del__(self): + self.close() +
