@@ -27,7 +27,7 @@ def __init__(
2727 self .opened_dependencies : List [Any ] = []
2828 self .sub_contexts : "List[Any]" = []
2929 self .initial_cache = initial_cache or {}
30- self .replaced_funcs = replaced_deps or {}
30+ self .replaced_deps = replaced_deps or {}
3131 self .propagate_excs = exception_propagation
3232
3333 def traverse_deps ( # noqa: C901, WPS210
@@ -93,7 +93,7 @@ def traverse_deps( # noqa: C901, WPS210
9393 resolved_kwargs .update (subdep .kwargs )
9494 # We try to grab possible replacement for
9595 # function if any. Otherwise, original subdependency is returned.
96- target_dependency = self .replaced_funcs .get (
96+ target_dependency = self .replaced_deps .get (
9797 subdep .dependency ,
9898 subdep .dependency ,
9999 )
@@ -113,7 +113,7 @@ def traverse_deps( # noqa: C901, WPS210
113113 user_kwargs .update (kwargs )
114114 # From dict of replaced functions,
115115 # we grab possible replacement or original function.
116- target_dependency = self .replaced_funcs .get (
116+ target_dependency = self .replaced_deps .get (
117117 dep .dependency ,
118118 dep .dependency ,
119119 )
@@ -186,7 +186,7 @@ def resolver(self, executed_func: Any, initial_cache: Dict[Any, Any]) -> Any:
186186 ctx = SyncResolveContext (
187187 graph = executed_func ,
188188 initial_cache = initial_cache ,
189- replaced_deps = self .replaced_funcs ,
189+ replaced_deps = self .replaced_deps ,
190190 exception_propagation = self .propagate_excs ,
191191 )
192192 self .sub_contexts .append (ctx )
@@ -308,7 +308,7 @@ async def resolver(self, executed_func: Any, initial_cache: Dict[Any, Any]) -> A
308308 ctx = AsyncResolveContext (
309309 graph = executed_func ,
310310 initial_cache = initial_cache ,
311- replaced_deps = self .replaced_funcs ,
311+ replaced_deps = self .replaced_deps ,
312312 exception_propagation = self .propagate_excs ,
313313 ) # type: ignore
314314 self .sub_contexts .append (ctx )
0 commit comments