import os

from sqlalchemy.ext.automap import automap_base
from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
from sqlalchemy.orm.scoping import scoped_session
from sqlalchemy.pool import NullPool

DB_URL = os.environ.get('DB_URL')

if not DB_URL:
    raise ValueError("DB_URL not present in the environment")

Base = automap_base()
engine = create_engine(DB_URL, poolclass=NullPool)
Base.prepare(engine, reflect=True)

session_factory = sessionmaker(bind=engine, expire_on_commit=False)
Session = scoped_session(session_factory)

@@ -221,86 +221,166 @@
 ol%0A%0A
-DB_URL = os.environ.get('DB_URL')%0A%0Aif not DB_URL:%0A    raise ValueError(%22DB_URL
+AIRFLOW_CONN_MYSQL_TRACKER = os.environ.get('AIRFLOW_CONN_MYSQL_TRACKER')%0A%0Aif not AIRFLOW_CONN_MYSQL_TRACKER:%0A    raise ValueError(%22AIRFLOW_CONN_MYSQL_TRACKER
  not

Add Mysql Tracker database to store our data