Commit ee008d4d authored by Dion Häfner's avatar Dion Häfner
Browse files

[distributed] support functions without arguments in dist_context_only

parent 7eaa5c8e
......@@ -27,7 +27,7 @@ def veros_method(function=None, **kwargs):
>>> from veros import Veros, veros_method
>>> class MyModel(Veros):
>>> @veros_method
>>> def set_topography(self):
......@@ -143,14 +143,19 @@ def _veros_method(function, inline=False, dist_safe=True, local_vars=None,
def dist_context_only(function):
def dist_context_only_wrapper(vs, arr, *args, **kwargs):
def dist_context_only_wrapper(*args, **kwargs):
# args are assumed to be (), (vs,), or (vs, arr, ...)
from . import runtime_state as rst
if rst.proc_num == 1 or not CONTEXT.is_dist_safe:
# no-op for sequential execution
return arr
# return input array unchanged
return args[2]
except IndexError:
return function(vs, arr, *args, **kwargs)
return function(*args, **kwargs)
return dist_context_only_wrapper
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment