Merge branch 'tests' of https://github.com/naschmitz/Xee into tests

examples/ee_to_zarr.py

@@ -24,7 +24,10 @@
 import xee
 
 import ee
-
+from google.auth import identity_pool
+import json
+import os
+from google import auth
 
 logger = logging.getLogger(__name__)
 logger.setLevel(logging.INFO)
@@ -64,14 +67,23 @@ def _parse_chunks_str(chunks_str: str) -> dict[str, int]:
   return chunks
 
 
+def _read_creds() -> identity_pool.Credentials:
+  with open(os.environ['GOOGLE_APPLICATION_CREDENTIALS']) as json_file:
+    json_config_info = json.loads(json_file.read())
+    credentials = identity_pool.Credentials.from_info(json_config_info)
+    return credentials.with_scopes(
+      ['https://www.googleapis.com/auth/cloud-platform', 'https://www.googleapis.com/auth/earthengine'])
+
+
 def main(argv: list[str]) -> None:
   assert _INPUT.value, 'Must specify --input'
   assert _OUTPUT.value, 'Must specify --output'
 
   source_chunks = {'time': 24}
   target_chunks = dict(source_chunks, **_parse_chunks_str(_TARGET_CHUNKS.value))
 
-  ee.Initialize(opt_url='https://earthengine-highvolume.googleapis.com')
+  credentials, project = auth.default()
+  ee.Initialize(credentials=_read_creds(), opt_url='https://earthengine-highvolume.googleapis.com')
 
   ds = xr.open_dataset(
       _INPUT.value,

setup.py

@@ -29,6 +29,7 @@
     "dask",
     "pytest",
     "pyink",
+    "dask",
 ]
 
 examples_require = [

xee/ext_integration_test.py

@@ -22,6 +22,17 @@
 import xee
 
 import ee
+from google.auth import identity_pool
+import json
+import os
+from google import auth
+
+def _read_creds() -> identity_pool.Credentials:
+  with open(os.environ['GOOGLE_APPLICATION_CREDENTIALS']) as json_file:
+    json_config_info = json.loads(json_file.read())
+    credentials = identity_pool.Credentials.from_info(json_config_info)
+    return credentials.with_scopes(
+      ['https://www.googleapis.com/auth/cloud-platform', 'https://www.googleapis.com/auth/earthengine'])
 
 
 def init_ee_for_tests():

xee/micro_benchmarks.py

@@ -29,15 +29,28 @@
 import xee
 
 import ee
+from google.auth import identity_pool
+import json
+import os
+from google import auth
 
 
 REPEAT = 10
 LOOPS = 1
 PROFILE = False
 
 
+def _read_creds() -> identity_pool.Credentials:
+  with open(os.environ['GOOGLE_APPLICATION_CREDENTIALS']) as json_file:
+    json_config_info = json.loads(json_file.read())
+    credentials = identity_pool.Credentials.from_info(json_config_info)
+    return credentials.with_scopes(
+      ['https://www.googleapis.com/auth/cloud-platform', 'https://www.googleapis.com/auth/earthengine'])
+
+
 def init_ee_for_tests():
-  ee.Initialize(opt_url='https://earthengine-highvolume.googleapis.com')
+  credentials, project = auth.default()
+  ee.Initialize(credentials=_read_creds(), opt_url='https://earthengine-highvolume.googleapis.com')
 
 
 def open_dataset() -> None: