else None,
override_document_type_id=doc_type.id if doc_type else None,
override_tag_ids=tag_ids,
+ override_owner_id=rule.owner.id if rule.owner else None,
)
+ consume_tasks.append(consume_task)
+
processed_attachments += 1
else:
self.log(
override_correspondent_id=correspondent.id if correspondent else None,
override_document_type_id=doc_type.id if doc_type else None,
override_tag_ids=tag_ids,
+ override_owner_id=rule.owner.id if rule.owner else None,
)
+
+ mail_action_task = apply_mail_action.s(
+ M=M,
+ action=get_rule_action(rule),
+ message_uid=message.uid,
+ parameter=rule.action_parameter,
+ )
+
+ (consume_task | mail_action_task).delay()
+
processed_elements = 1
return processed_elements