bundle_adb_360/src/b_historical/3c_loadSCD1DimensionsHist.py [126:154]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
bContinue = True
while bContinue:
    try:
        tDelta.alias('t') \
            .merge(
                wmdf.alias('u'),
                't.tablename = u.tablename'
            ) \
            .whenMatchedUpdate(set=
            {
                'tablename' : 'u.tablename',
                'lastCommitKey' : 'u.lastCommitKey',
                'lastTimeStamp' : 'u.lastTimeStamp'
            }
            ) \
            .whenNotMatchedInsert(values=
            {
                'tablename' : 'u.tablename',
                'lastCommitKey' : 'u.lastCommitKey',
                'lastTimeStamp' : 'u.lastTimeStamp'
            }
            ) \
            .execute()
        bContinue = False
    except Exception as e:
        if "ConcurrentAppendException" in str(e):
            bContinue = True
            print('caught ConcurrentAppendException!')
            sleep(20)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



bundle_adb_360/src/b_historical/3d_loadSCD2DimensionsHist.py [81:109]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
bContinue = True
while bContinue:
    try:
        tDelta.alias('t') \
            .merge(
                wmdf.alias('u'),
                't.tablename = u.tablename'
            ) \
            .whenMatchedUpdate(set=
            {
                'tablename' : 'u.tablename',
                'lastCommitKey' : 'u.lastCommitKey',
                'lastTimeStamp' : 'u.lastTimeStamp'
            }
            ) \
            .whenNotMatchedInsert(values=
            {
                'tablename' : 'u.tablename',
                'lastCommitKey' : 'u.lastCommitKey',
                'lastTimeStamp' : 'u.lastTimeStamp'
            }
            ) \
            .execute()
        bContinue = False
    except Exception as e:
        if "ConcurrentAppendException" in str(e):
            bContinue = True
            print('caught ConcurrentAppendException!')
            sleep(20)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -