Log applying action

src/documents/consumer.py

@@ -620,6 +620,9 @@ class Consumer(LoggingMixin):
                 WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
             ):
                 for action in workflow.actions.all():
+                    self.log.info(
+                        f"Applying overrides in {action} from {workflow}",
+                    )
                     if action.assign_title is not None:
                         template_overrides.title = action.assign_title
                     if action.assign_tags is not None:

src/documents/signals/handlers.py

@@ -520,14 +520,26 @@ def add_to_index(sender, document, **kwargs):
 
 
 def run_workflow_added(sender, document: Document, logging_group=None, **kwargs):
-    run_workflow(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_ADDED, document)
+    run_workflow(
+        WorkflowTrigger.WorkflowTriggerType.DOCUMENT_ADDED,
+        document,
+        logging_group,
+    )
 
 
 def run_workflow_updated(sender, document: Document, logging_group=None, **kwargs):
-    run_workflow(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, document)
+    run_workflow(
+        WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
+        document,
+        logging_group,
+    )
 
 
-def run_workflow(trigger_type: WorkflowTrigger.WorkflowTriggerType, document: Document):
+def run_workflow(
+    trigger_type: WorkflowTrigger.WorkflowTriggerType,
+    document: Document,
+    logging_group=None,
+):
     for workflow in Workflow.objects.filter(
         enabled=True,
         triggers__type=trigger_type,
@@ -538,6 +550,10 @@ def run_workflow(trigger_type: WorkflowTrigger.WorkflowTriggerType, document: Do
             trigger_type,
         ):
             for action in workflow.actions.all():
+                logger.info(
+                    f"Applying {action} from {workflow}",
+                    extra={"group": logging_group},
+                )
                 if action.assign_tags.all().count() > 0:
                     document.tags.add(*action.assign_tags.all())
 

src/documents/tasks.py

@@ -219,6 +219,7 @@ def bulk_update_documents(document_ids):
         document_updated.send(
             sender=None,
             document=doc,
+            logging_group=uuid.uuid4(),
         )
         post_save.send(Document, instance=doc, created=False)