Revert store close apart from S3

src/maggma/api/resource/post_resource.py

@@ -13,7 +13,6 @@
 from maggma.api.utils import STORE_PARAMS, merge_queries
 from maggma.core import Store
 from maggma.stores import S3Store
-from maggma.core.store import StoreError
 
 
 class PostOnlyResource(Resource):
@@ -145,11 +144,6 @@ def search(**queries: Dict[str, STORE_PARAMS]) -> Dict:
                         detail="Server timed out trying to obtain data. Try again with a smaller request, "
                         "or remove sorting fields and sort data locally.",
                     )
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
 
             operator_meta = {}
 

src/maggma/api/resource/read_resource.py

@@ -15,7 +15,6 @@
 from maggma.api.utils import STORE_PARAMS, merge_queries, serialization_helper
 from maggma.core import Store
 from maggma.stores import MongoStore, S3Store
-from maggma.core.store import StoreError
 
 import orjson
 
@@ -169,12 +168,6 @@ def get_by_key(
                     detail=f"Item with {self.store.key} = {key} not found",
                 )
 
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
-
             for operator in self.query_operators:
                 item = operator.post_process(item, {})
 
@@ -280,12 +273,6 @@ def search(**queries: Dict[str, STORE_PARAMS]) -> Union[Dict, Response]:
                         " or remove sorting fields and sort data locally.",
                     )
 
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
-
             operator_meta = {}
 
             for operator in self.query_operators:

src/maggma/api/resource/s3_url.py

@@ -10,7 +10,6 @@
 from maggma.api.resource import Resource, HeaderProcessor
 from maggma.api.utils import serialization_helper
 from maggma.stores.aws import S3Store
-from maggma.core.store import StoreError
 
 import orjson
 
@@ -115,12 +114,6 @@ def get_by_key(
                     ),
                 )
 
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
-
             requested_datetime = datetime.utcnow()
             expiry_datetime = requested_datetime + timedelta(seconds=self.url_lifetime)
 

src/maggma/api/resource/submission.py

@@ -16,7 +16,6 @@
 from maggma.api.utils import STORE_PARAMS, merge_queries
 from maggma.core import Store
 from maggma.stores import S3Store
-from maggma.core.store import StoreError
 
 
 class SubmissionResource(Resource):
@@ -175,12 +174,6 @@ def get_by_key(
                     detail=f"Item with submission ID = {key} not found",
                 )
 
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
-
             for operator in self.get_query_operators:  # type: ignore
                 item = operator.post_process(item, {})
 
@@ -262,12 +255,6 @@ def search(**queries: STORE_PARAMS):
                         "or remove sorting fields and sort data locally.",
                     )
 
-            try:
-                self.store.close()
-            except (StoreError, AttributeError):
-                # If no connections are present, then move on
-                pass
-
             meta = Meta(total_doc=count)
 
             for operator in self.get_query_operators:  # type: ignore