def resetdb():
    from airflow import models

    logging.info("Dropping tables that exist")
    models.Base.metadata.drop_all(settings.engine)
    mc = MigrationContext.configure(settings.engine)
    if mc._version.exists(settings.engine):
        mc._version.drop(settings.engine)
    initdb()
Clear out the database
dataset/ETHPy150Open airbnb/airflow/airflow/utils/db.py/resetdb