diff --git a/distarray/dist/distarray.py b/distarray/dist/distarray.py index 7592a7a2..8ed3ffe9 100644 --- a/distarray/dist/distarray.py +++ b/distarray/dist/distarray.py @@ -233,11 +233,11 @@ def get_dist_matrix(self): return result def fill(self, value): - value_key = self.context._generate_key() - self.context._push({value_key:value}) - self.context._execute('%s.fill(%s)' % (self.key, value_key)) + def inner_fill(arr, value): + arr.fill(value) + self.context.apply(inner_fill, args=(self.key, value)) - #TODO FIXME: implement axis and out kwargs. + # TODO FIXME: implement axis and out kwargs. def sum(self, axis=None, dtype=None, out=None): if axis or out is not None: _raise_nie()