From 0fa11f58542b60f4dec0ba130dad99d0472e4188 Mon Sep 17 00:00:00 2001 From: milancurcic Date: Fri, 28 Apr 2023 10:45:32 -0400 Subject: [PATCH] Handle exception in rowsize func --- clouddrift/adapters/gdp.py | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/clouddrift/adapters/gdp.py b/clouddrift/adapters/gdp.py index 66510745..5f6f74da 100644 --- a/clouddrift/adapters/gdp.py +++ b/clouddrift/adapters/gdp.py @@ -271,10 +271,19 @@ def drogue_presence(lost_time, time) -> bool: def rowsize(index: int, **kwargs) -> int: - return xr.open_dataset( - os.path.join(kwargs["tmp_path"], kwargs["filename_pattern"].format(id=index)), - decode_cf=False, - decode_times=False, - concat_characters=False, - decode_coords=False, - ).dims["obs"] + try: + return xr.open_dataset( + os.path.join( + kwargs["tmp_path"], kwargs["filename_pattern"].format(id=index) + ), + decode_cf=False, + decode_times=False, + concat_characters=False, + decode_coords=False, + ).dims["obs"] + except Exception as e: + print( + f"Error processing {os.path.join(kwargs['tmp_path'], kwargs['filename_pattern'].format(id=index))}" + ) + print(str(e)) + return 0