This commit is contained in:
Nuno Campos
2025-05-08 16:49:01 -07:00
parent 09fdc14d0a
commit d33c5a20e4
2 changed files with 2 additions and 2 deletions
+1 -1
View File
@@ -145,7 +145,7 @@ def task(
func.__name__ = name
call_func = functools.partial(
call, func, retry=retry_policies, cache=cache_policy
call, func, retry=retry_policies, cache_policy=cache_policy
)
object.__setattr__(call_func, "_is_pregel_task", True)
return functools.update_wrapper(call_func, func)
+1 -1
View File
@@ -251,7 +251,7 @@ def call(
func,
(args, kwargs),
retry=retry,
cache=cache_policy,
cache_policy=cache_policy,
callbacks=config["callbacks"],
)
return fut