Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion imod/formats/prj/prj.py
Original file line number Diff line number Diff line change
Expand Up @@ -621,7 +621,7 @@ def _create_dataarray(
dav = _create_dataarray_from_values(values_valid, headers_values, dim=dim)
dap.name = "tmp"
dav.name = "tmp"
da = xr.merge((dap, dav), join="outer")["tmp"]
da = xr.merge((dap, dav), join="outer", compat="no_conflicts")["tmp"]
elif paths_valid:
# Only paths provided
da = _create_dataarray_from_paths(paths_valid, headers_paths, dim=dim)
Expand Down
6 changes: 3 additions & 3 deletions imod/mf6/gwfgwf.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,9 @@ def __init__(

auxiliary_variables = [var for var in [angldegx, cdist] if var is not None]
if auxiliary_variables:
self.dataset["auxiliary_data"] = xr.merge(auxiliary_variables).to_array(
name="auxiliary_data"
)
self.dataset["auxiliary_data"] = xr.merge(
auxiliary_variables, compat="no_conflicts"
).to_array(name="auxiliary_data")
expand_transient_auxiliary_variables(self)

def set_options(
Expand Down
6 changes: 3 additions & 3 deletions imod/mf6/gwtgwt.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,9 @@ def __init__(

auxiliary_variables = [var for var in [angldegx, cdist] if var is not None]
if auxiliary_variables:
self.dataset["auxiliary_data"] = xr.merge(auxiliary_variables).to_array(
name="auxiliary_data"
)
self.dataset["auxiliary_data"] = xr.merge(
auxiliary_variables, compat="no_conflicts"
).to_array(name="auxiliary_data")
expand_transient_auxiliary_variables(self)

def set_options(
Expand Down
5 changes: 4 additions & 1 deletion imod/mf6/hfb.py
Original file line number Diff line number Diff line change
Expand Up @@ -522,7 +522,10 @@ def line_data(self) -> GeoDataFrameType:
def line_data(self, value: GeoDataFrameType) -> None:
variables_for_gdf = self._get_variable_names_for_gdf()
self.dataset = self.dataset.merge(
value.to_xarray(), overwrite_vars=variables_for_gdf, join="right"
value.to_xarray(),
overwrite_vars=variables_for_gdf,
join="right",
compat="no_conflicts",
)

def _render(self, directory, pkgname, globaltimes, binary):
Expand Down
9 changes: 7 additions & 2 deletions imod/typing/grid.py
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ def merge(
objects: Sequence[GridDataArray | GridDataset], *args, **kwargs
) -> GridDataset:
return _type_dispatch_functions_on_grid_sequence(
objects, xu.merge, xr.merge, *args, **kwargs
objects, xu.merge, xr.merge, *args, compat="no_conflicts", **kwargs
)


Expand Down Expand Up @@ -263,7 +263,12 @@ def merge_with_dictionary(
**kwargs,
):
return _type_dispatch_functions_on_dict(
variables_to_merge, merge_unstructured_dataset, xr.merge, *args, **kwargs
variables_to_merge,
merge_unstructured_dataset,
xr.merge,
*args,
compat="no_conflicts",
**kwargs,
)


Expand Down
2 changes: 1 addition & 1 deletion imod/typing/structured.py
Original file line number Diff line number Diff line change
Expand Up @@ -245,7 +245,7 @@ def merge_partitions(
merged_ls = []
for key in unique_keys:
merged_ls.append(_merge_partitions([da[key] for da in das]).rename(key))
return xr.merge(merged_ls)
return xr.merge(merged_ls, compat="no_conflicts")
elif isinstance(first_item, xr.DataArray):
# Store name to rename after concatenation
name = first_item.name
Expand Down
Loading