Coverage for async_durable_execution/_extension/__init__.py: 100%

1"""Compatibility aliases for the former private operation package.""" 

2 

3from importlib import import_module 

4import sys 

5 

6 

7_OPERATION_MODULES = ( 

8 "flow", 

9 "map", 

10 "parallel", 

11 "recurse", 

12 "replay_safe", 

13 "wait_for_callback", 

14 "wait_for_condition", 

15 "with_retry", 

16) 

17 

18for _module_name in _OPERATION_MODULES: 

19 _module = import_module(f"async_durable_execution._operation.{_module_name}") 

20 sys.modules[f"{__name__}.{_module_name}"] = _module 

21 globals()[_module_name] = _module 

22 

23del _module, _module_name