def pull_from_email_account(email_account):
 email_account = frappe.get_doc(u'Email Account', email_account)
 email_account.receive()

def pull_from_email_account ( email_account ) : email_account = frappe . get_doc ( u'Email Account' , email_account ) email_account . receive ( )
runs within a worker process .