@task
def consume_email(email_text, **kwargs):
 res = save_from_email_reply(email_text)
 if (not res):
  log.error('Failed to save email.')

@ task def consume_email ( email_text , ** kwargs ) : res = save_from_email_reply ( email_text ) if ( not res ) : log . error ( 'Failed to save email.' )
parse emails and save notes .