def connect(self): # noqa if not database_exists(self.engine.url): create_database(self.engine.url) self.session = sessionmaker(bind=self.engine)() _Base.metadata.create_all(self.engine)