renamed func argument to _job_pointwise function to provided_func to avoid overlap with func argument of functools.partial function
This commit is contained in:
parent
b06a272586
commit
793f4e22ba
|
@ -1402,7 +1402,7 @@ class Result:
|
||||||
|
|
||||||
def _job_pointwise(self,
|
def _job_pointwise(self,
|
||||||
group: str,
|
group: str,
|
||||||
func: Callable,
|
provided_func: Callable,
|
||||||
datasets: Dict[str, str],
|
datasets: Dict[str, str],
|
||||||
args: Dict[str, str],
|
args: Dict[str, str],
|
||||||
lock: LockBase) -> List[Union[None, Any]]:
|
lock: LockBase) -> List[Union[None, Any]]:
|
||||||
|
@ -1418,7 +1418,7 @@ class Result:
|
||||||
'meta': {k:(v.decode() if not h5py3 and type(v) is bytes else v) \
|
'meta': {k:(v.decode() if not h5py3 and type(v) is bytes else v) \
|
||||||
for k,v in loc.attrs.items()}}
|
for k,v in loc.attrs.items()}}
|
||||||
lock.release()
|
lock.release()
|
||||||
r = func(**datasets_in,**args)
|
r = provided_func(**datasets_in,**args)
|
||||||
return [group,r]
|
return [group,r]
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print(f'Error during calculation: {err}.')
|
print(f'Error during calculation: {err}.')
|
||||||
|
@ -1459,7 +1459,7 @@ class Result:
|
||||||
print('No matching dataset found, no data was added.')
|
print('No matching dataset found, no data was added.')
|
||||||
return
|
return
|
||||||
|
|
||||||
default_arg = partial(self._job_pointwise,func=func,datasets=datasets,args=args,lock=lock)
|
default_arg = partial(self._job_pointwise,provided_func=func,datasets=datasets,args=args,lock=lock)
|
||||||
|
|
||||||
for group,result in util.show_progress(pool.imap_unordered(default_arg,groups),len(groups)): #type: ignore
|
for group,result in util.show_progress(pool.imap_unordered(default_arg,groups),len(groups)): #type: ignore
|
||||||
if not result:
|
if not result:
|
||||||
|
|
Loading…
Reference in New Issue