Send auth instead

earthaccess/api.py

@@ -176,7 +176,6 @@ def download(
 def open(
     granules: Union[List[str], List[earthaccess.results.DataGranule]],
     provider: Optional[str] = None,
-    store: Optional[Store] = None,
 ) -> List[AbstractFileSystem]:
     """Returns a list of fsspec file-like objects that can be used to access files
     hosted on S3 or HTTPS by third party libraries like xarray.
@@ -187,8 +186,7 @@ def open(
     Returns:
         a list of s3fs "file pointers" to s3 files.
     """
-    store = store or earthaccess.__store__
-    results = store.open(granules=granules, provider=provider)
+    results = earthaccess.__store__.open(granules=granules, provider=provider)
     return results
 
 

earthaccess/store.py

@@ -20,6 +20,7 @@
 from .daac import DAAC_TEST_URLS, find_provider
 from .results import DataGranule
 from .search import DataCollections
+from .auth import Auth
 
 
 class EarthAccessFile(fsspec.spec.AbstractBufferedFile):
@@ -33,8 +34,8 @@ def __getattr__(self, method: str) -> Any:
     def __reduce__(self) -> Any:
         return make_instance, (
             type(self.f),
-            self.f,
-            earthaccess.__store__,
+            self.granule,
+            earthaccess.__auth__,
             self.f.__reduce__(),
         )
 
@@ -63,12 +64,19 @@ def multi_thread_open(data: tuple) -> EarthAccessFile:
     return fileset
 
 
-def make_instance(cls: Any, granule: DataGranule, store, _reduce: Any) -> EarthAccessFile:
-    if store.running_in_aws and cls is not s3fs.S3File:
+def make_instance(
+    cls: Any, granule: DataGranule, auth: Auth, _reduce: Any
+) -> EarthAccessFile:
+    # Attempt to re-authenticate
+    if not earthaccess.__auth__.authenticated:
+        earthaccess.__auth__ = auth
+        earthaccess.login()
+
+    if earthaccess.__store__.running_in_aws and cls is not s3fs.S3File:
         # On AWS but not using a S3File. Reopen the file in this case for direct S3 access.
         # NOTE: This uses the first data_link listed in the granule. That's not
         #       guaranteed to be the right one.
-        return EarthAccessFile(earthaccess.open([granule], store=store)[0], granule)
+        return EarthAccessFile(earthaccess.open([granule])[0], granule)
     else:
         func = _reduce[0]
         args = _reduce[1]