(self, connection: BaseDBAsyncClient, apps_config: dict[str, dict])
| 38 | |
| 39 | class MigrationExecutor: |
| 40 | def __init__(self, connection: BaseDBAsyncClient, apps_config: dict[str, dict]) -> None: |
| 41 | self.connection = connection |
| 42 | self.recorder = MigrationRecorder(connection) |
| 43 | self.loader = MigrationLoader(apps_config, self.recorder, load=False) |
| 44 | self._full_plan_cache: list[MigrationKey] | None = None |
| 45 | self._logger = logging.getLogger(__name__) |
| 46 | |
| 47 | async def migrate( |
| 48 | self, |
nothing calls this directly
no test coverage detected