(env_fn: Callable)
| 10 | |
| 11 | |
| 12 | def parallel_wrapper_fn(env_fn: Callable) -> Callable: |
| 13 | def par_fn(**kwargs): |
| 14 | env = env_fn(**kwargs) |
| 15 | env = aec_to_parallel_wrapper(env) |
| 16 | return env |
| 17 | |
| 18 | return par_fn |
| 19 | |
| 20 | |
| 21 | def aec_wrapper_fn(par_env_fn: Callable) -> Callable: |
no outgoing calls
no test coverage detected
searching dependent graphs…