def resetdb():
 from airflow import models
 logging.info(u'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()

def resetdb ( ) : from airflow import models logging . info ( u'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 .