Updates from adi_py-v3.19.2

ARM-DOE · May 17, 2023 · 2436d30 · 2436d30
1 parent 53aa022
commit 2436d30
Show file tree

Hide file tree

Showing 16 changed files with 1,896 additions and 865 deletions.
diff --git a/packages/adi_py/adi_py/__init__.py b/packages/adi_py/adi_py/__init__.py
@@ -14,6 +14,8 @@
 
 from .process import Process
 
+from .utils import DatastreamIdentifier
+
 from .xarray_accessors import ADIDatasetAccessor, ADIDataArrayAccessor
 
 from .exception import SkipProcessingIntervalException

diff --git a/packages/adi_py/adi_py/constants.py b/packages/adi_py/adi_py/constants.py
@@ -26,10 +26,11 @@ class SpecialXrAttributes:
     SOURCE_VAR_NAME = '__source_var_name'
     COORDINATE_SYSTEM = '__coordsys_name'
     OUTPUT_TARGETS = '__output_targets'
-    DATASTREAM_NAME = '__datastream_name'
+    DATASTREAM_DSID = '__datastream_dsid'
     DATASET_TYPE = '__dataset_type'
     OBS_INDEX = '__obs_index'
 
+
 class ADIAtts:
     MISSING_VALUE = 'missing_value'
     LONG_NAME = 'long_name'
@@ -64,4 +65,3 @@ class ADIDatasetType(Enum):
     RETRIEVED = 1
     TRANSFORMED = 2
     OUTPUT = 3
-
diff --git a/packages/adi_py/adi_py/logger.py b/packages/adi_py/adi_py/logger.py
@@ -25,7 +25,7 @@ def warning(message):
 
     @staticmethod
     def error(message):
-        dsproc.error(message)
+        dsproc.error(message, None)
 
     @staticmethod
     def exception(message):

diff --git a/packages/adi_py/adi_py/process.py b/packages/adi_py/adi_py/process.py