#NEWLINE# @ app . task #NEWLINE# @ events . creates_task ( events . HARVESTER_RUN ) #NEWLINE# def run_harvester( harvester_name , start_date = None , end_date = None ) : #NEWLINE# #INDENT# logger . info ( 'Running harvester "{}"' . format ( harvester_name ) ) #NEWLINE# start_date = ( start_date or ( date . today ( ) - timedelta ( settings . DAYS_BACK ) ) ) #NEWLINE# end_date = ( end_date or date . today ( ) ) #NEWLINE# normalization = begin_normalization . s ( harvester_name ) #NEWLINE# start_harvest = harvest . si ( harvester_name , timestamp ( ) , start_date = start_date , end_date = normalization ) #NEWLINE# ( start_harvest | normalization ) . apply_async ( )