#NEWLINE# @ task_autoretry ( default_retry_delay = settings . CELERY_RETRY_DELAY , max_retries = settings . CELERY_MAX_RETRIES , throws = events . Skip ) #NEWLINE# @ events . logged ( events . PROCESSING , 'normalized' ) #NEWLINE# def process_normalized( normalized_doc , raw_doc , **kwargs ) : #NEWLINE# #INDENT# if ( not normalized_doc ) : #NEWLINE# #INDENT# raise events . Skip ( 'Not processing document with id {}' . format ( raw_doc [ 'docID' ] ) ) #NEWLINE# #UNINDENT# processing . process_normalized ( raw_doc , normalized_doc , kwargs )