#NEWLINE# def pipeline_event_loader_args( self , dates ) : #NEWLINE# #INDENT# ( _ , mapping ) = super ( BlazeDividendsByExDateLoaderTestCase , self ) . pipeline_event_loader_args ( self ) #NEWLINE# return ( bz . Data ( pd . concat ( ( pd . DataFrame ( { #NEWLINE# #INDENT# EX_DATE_FIELD_NAME : df [ EX_DATE_FIELD_NAME ] , #NEWLINE# TS_FIELD_NAME : df [ TS_FIELD_NAME ] , #NEWLINE# SID_FIELD_NAME : sid , #NEWLINE# CASH_AMOUNT_FIELD_NAME : df [ CASH_AMOUNT_FIELD_NAME ] , #NEWLINE# #UNINDENT# } ) for ( sid , df ) in iteritems ( mapping ) ) ) . reset_index ( drop = True ) ) , )