

@event.listens_for(settings.engine, 'checkout')
def checkout(dbapi_connection, connection_record, connection_proxy):
    pid = os.getpid()
    if (connection_record.info['pid'] != pid):
        connection_record.connection = connection_proxy.connection = None
        raise exc.DisconnectionError('Connection record belongs to pid {}, attempting to check out in pid {}'.format(connection_record.info['pid'], pid))

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