(self)
| 82 | await self.write_space_model_providers() |
| 83 | |
| 84 | async def create_tables(self): |
| 85 | # create tables |
| 86 | async with self.get_db_engine().connect() as conn: |
| 87 | await conn.run_sync(self.meta.create_all) |
| 88 | |
| 89 | await conn.commit() |
| 90 | |
| 91 | # ======= write initial data ======= |
| 92 | |
| 93 | # write initial metadata |
| 94 | self.ap.logger.info('Creating initial metadata...') |
| 95 | for item in metadata.initial_metadata: |
| 96 | # check if the item exists |
| 97 | result = await self.execute_async( |
| 98 | sqlalchemy.select(metadata.Metadata).where(metadata.Metadata.key == item['key']) |
| 99 | ) |
| 100 | row = result.first() |
| 101 | if row is None: |
| 102 | await self.execute_async(sqlalchemy.insert(metadata.Metadata).values(item)) |
| 103 | |
| 104 | async def write_space_model_providers(self): |
| 105 | space_models_gateway_api_url = self.ap.instance_config.data.get('space', {}).get( |
no test coverage detected