

def flush(self, engine):
    'Delete all metadata associated with engine.'
    self.pool.terminate()
    self.pool.join()
    (db_key, ipydb_engine) = get_metadata_engine(engine)
    del self.databases[ipydb_engine]
    delete_schema(ipydb_engine)
    create_schema(ipydb_engine)
    self.pool = ThreadPool((multiprocessing.cpu_count() * 2))

dataset/ETHPy150Open jaysw/ipydb/ipydb/metadata/__init__.py MetaDataAccessor.flush/VarMisuse@46/66 `db_key`->`ipydb_engine`