#NEWLINE# def _schedule_deferred( self , * args ) : #NEWLINE# #INDENT# rv = self . cb . upsertMulti ( self . kv , format = FMT_BYTES ) #NEWLINE# rv . addCallback ( rv . _schedule_deferred ) #NEWLINE# self . opcount += options . batch