The function blocks described in this section can only be used in Python agents in batch workflows. The available function blocks are:

• beginBatch

• drain

• endBatch

• endBatchHinted

• cancelBatch

• splittingBatch

• commit

• rollback

beginBatch

...

def beginBatch()

def beginBatch():
    debug('beginBatch called')

drain

...

def drain()

def drain():
    debug('drain called')
    udrRoute(myLastUDR) 

endBatch 

...

def endBatch()

def endBatch():
    debug('endBatch called')

endBatchHinted

This function block is called when another agent has called hintEndBatch. The collection agent may choose to ignore this method, that is, not to implement it if it cannot be supported.

def endBatchHinted()

def endBatchHinted():
    debug('endBatchHinted called')

cancelBatch

This function block is executed if a Cancel Batch is emitted anywhere in the workflow.

def cancelBatch()

def cancelBatch():
    debug('cancelBatch called')

splittingBatch

This function block is called when the collection agent has split the input batch. If the agent keeps internal buffers to be flushed differently depending on the nature of the transaction, this method serves as a hint to the drain call.

def splittingBatch()

def splittingBatch():
    debug('splittingBatch called')

commit

This function block is executed for each batch when the transaction is successful. If the commit block fails with an exception, it will be executed again until it succeeds.

def commit()

isRecoveryCommit = True

def initialize():
    debug('initialize called')

def beginBatch():
    global isRecoveryCommit
    isRecoveryCommit = False

def commit():
    if isRecoveryCommit:
        debug('this is a recovery commit, it is executed immediately after initialize')
    else:
        debug('this is a normal commit')

rollback

This function block is executed for a batch if it fails.

def rollback()

def rollback():
    debug('rollback called')

...