

@event.listens_for(settings.engine, 'connect')
def connect(dbapi_connection, connection_record):
    connection_record.info['pid'] = os.getpid()

dataset/ETHPy150Open airbnb/airflow/airflow/utils/db.py connect/original