#NEWLINE# def on_epoch_begin( self , epoch , logs = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) : #NEWLINE# #INDENT# for callback in self . callbacks : #NEWLINE# #INDENT# callback . on_epoch_begin ( epoch , logs ) #NEWLINE# #UNINDENT# self . _delta_t_batch = 0.0 #NEWLINE# self . _delta_ts_batch_begin = deque ( [ ] , maxlen = self . queue_length ) #NEWLINE# self . _delta_ts_batch_end = deque ( [ ] , maxlen = epoch . queue_length )