Skip to content

Commit c26eb7b

Browse files
authored
Add sort_time_dimension method and apply it in atmosphere and ocean CMORisers (#26)
1 parent 0db0de0 commit c26eb7b

3 files changed

Lines changed: 6 additions & 0 deletions

File tree

src/access_mopper/atmosphere.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ def select_and_process_variables(self):
3636

3737
required_vars = set(input_vars + bnds_required)
3838
self.load_dataset(required_vars=required_vars)
39+
self.sort_time_dimension()
3940

4041
# Handle the calculation type
4142
if calc["type"] == "direct":

src/access_mopper/base.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,10 @@ def _preprocess(ds):
6464
parallel=True, # <--- enables concurrent preprocessing
6565
)
6666

67+
def sort_time_dimension(self):
68+
if "time" in self.ds.dims:
69+
self.ds = self.ds.sortby("time")
70+
6771
def select_and_process_variables(self):
6872
raise NotImplementedError(
6973
"Subclasses must implement select_and_process_variables."

src/access_mopper/ocean.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@ def select_and_process_variables(self):
5656

5757
required_vars = set(input_vars)
5858
self.load_dataset(required_vars=required_vars)
59+
self.sort_time_dimension()
5960

6061
if calc["type"] == "direct":
6162
self.ds[self.cmor_name] = self.ds[input_vars[0]]

0 commit comments

Comments
 (0)