(module_type, module_info)
| 256 | |
| 257 | @staticmethod |
| 258 | async def _load_module(module_type, module_info): |
| 259 | module = import_module(module_info['module']) |
| 260 | return getattr(module, module_type)(module_info) |
| 261 | |
| 262 | async def create_relationships(self, relationships, operation): |
| 263 | for relationship in relationships: |