Topic Messages: dev.workflow.monitoring

Partition: 0   Offset: 56150   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:22.737 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T04:44:22.737040","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/95ba4d5dca69c54e5826ab1a3cb82a03020b607bc5a13424f52f485d47d17eec.pdf","document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"inv-good-hsand579.pdf","file_type":"application/pdf; name=\"INV-Good-hsand579.pdf\"","document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22"}],"subject":"Invoice Payment","task_id":"EML_TSK_edba3b32","message_id":"19d42347e2435927","source":"email-automation-service","uploaded_at":"2026-03-31T04:44:22.723417963Z","sender":"sachithya@redowl.ai","is_updated":true,"grant_id":"9bbd8a4a-4dea-4bd7-8509-14882689b7c9","isTemp":false,"attachment_id":"EML_ATT_b26db7c9","correlation_id":"EML_WK_9b59daca","document_type":""},"filename":"inv-good-hsand579.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56151   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:22.744 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T04:44:22.744459","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:22.744453","end_time":null,"execution_time":null}
Partition: 0   Offset: 56152   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:22.875 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T04:44:22.875750","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:22.744453","end_time":"2026-03-31T04:44:22.875739","execution_time":0.131286}
Partition: 0   Offset: 56153   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:22.877 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T04:44:22.877494","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":249130},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:22.877489","end_time":null,"execution_time":null}
Partition: 0   Offset: 56154   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:41.933 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T04:44:41.933330","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":249130},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:22.877489","end_time":"2026-03-31T04:44:41.933320","execution_time":19.055831}
Partition: 0   Offset: 56155   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:44:41.935 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T04:44:41.935863","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:41.935858","end_time":null,"execution_time":null}
Partition: 0   Offset: 56156   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:15.983 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T04:45:15.982923","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:44:41.935858","end_time":"2026-03-31T04:45:15.982909","execution_time":34.047051}
Partition: 0   Offset: 56157   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:15.988 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T04:45:15.988310","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:45:15.988299","end_time":null,"execution_time":null}
Partition: 0   Offset: 56158   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:44.396 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T04:45:44.396045","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:45:15.988299","end_time":"2026-03-31T04:45:44.396036","execution_time":28.407737}
Partition: 0   Offset: 56159   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:44.399 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T04:45:44.399061","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:45:44.399056","end_time":null,"execution_time":null}
Partition: 0   Offset: 56160   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:44.404 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T04:45:44.404327","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:45:44.399056","end_time":"2026-03-31T04:45:44.404315","execution_time":0.005259}
Partition: 0   Offset: 56161   Key: WF_DOCUMENT_ad241e3c   Timestamp: 2026-03-31 04:45:44.427 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ad241e3c","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T04:45:44.427141","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"01a0c722-3e85-44cc-a85f-8406e0cedd22","file_name":"inv-good-hsand579.pdf","content_length":249130,"execution_time":81.684523,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":81.647164}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56162   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:07.391 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T04:59:07.391363","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/1af0956d146172e6903454189b8ab0d669a09e72537126eee8f71796ebca23be.pdf","document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"invoice inv-1500 (2).pdf","file_type":"application/pdf; name=\"Invoice INV-1500 (2).pdf\"","document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d"}],"subject":"Urgent Invoice Payment","task_id":"EML_TSK_fb6f029a","message_id":"19d424209c3a6f71","source":"email-automation-service","uploaded_at":"2026-03-31T04:59:07.378498694Z","sender":"sachithya@redowl.ai","is_updated":true,"grant_id":"9bbd8a4a-4dea-4bd7-8509-14882689b7c9","isTemp":false,"attachment_id":"EML_ATT_94b62ddb","correlation_id":"EML_WK_f7593ccc","document_type":""},"filename":"invoice inv-1500 (2).pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56163   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:07.395 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T04:59:07.394946","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:07.394940","end_time":null,"execution_time":null}
Partition: 0   Offset: 56164   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:07.541 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T04:59:07.541854","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:07.394940","end_time":"2026-03-31T04:59:07.541843","execution_time":0.146903}
Partition: 0   Offset: 56165   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:07.543 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T04:59:07.543620","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":125706},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:07.543615","end_time":null,"execution_time":null}
Partition: 0   Offset: 56166   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:27.524 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T04:59:27.524225","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":125706},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:07.543615","end_time":"2026-03-31T04:59:27.524215","execution_time":19.9806}
Partition: 0   Offset: 56167   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 04:59:27.526 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T04:59:27.526418","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:27.526412","end_time":null,"execution_time":null}
Partition: 0   Offset: 56168   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:00.255 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T05:00:00.255262","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T04:59:27.526412","end_time":"2026-03-31T05:00:00.255251","execution_time":32.728839}
Partition: 0   Offset: 56169   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:00.262 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T05:00:00.262923","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T05:00:00.262915","end_time":null,"execution_time":null}
Partition: 0   Offset: 56170   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:28.931 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T05:00:28.931330","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T05:00:00.262915","end_time":"2026-03-31T05:00:28.931320","execution_time":28.668405}
Partition: 0   Offset: 56171   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:28.934 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T05:00:28.934665","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T05:00:28.934659","end_time":null,"execution_time":null}
Partition: 0   Offset: 56172   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:28.937 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T05:00:28.937781","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T05:00:28.934659","end_time":"2026-03-31T05:00:28.937771","execution_time":0.003112}
Partition: 0   Offset: 56173   Key: WF_DOCUMENT_14ea82a7   Timestamp: 2026-03-31 05:00:28.945 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_14ea82a7","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T05:00:28.945711","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"a06c7120-4ec6-47d3-8b62-a6b3853eab8d","file_name":"invoice inv-1500 (2).pdf","content_length":125706,"execution_time":81.5521,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":81.52785899999999}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56174   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:09.346 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T12:09:09.346578","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/157b0fb9832d68e56408ab66df5f5f6439e44fcee658f32fcad18ac674fdd3a2.pdf","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"jhta 03 - inv - 1005.pdf","file_type":"application/pdf; name=\"jhta 03 - inv - 1005.pdf\"","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0"}],"subject":"please proceed this invoice for payment","task_id":"EML_TSK_a7f26838","message_id":"19d43cb943983dff","source":"email-automation-service","uploaded_at":"2026-03-31T12:09:09.329866582Z","sender":"madhawa@redowl.ai","is_updated":true,"grant_id":"85f16bd6-9dc8-4f66-a5d4-2ef1dc1bf088","isTemp":false,"attachment_id":"EML_ATT_e885bd3f","correlation_id":"EML_WK_f1e7e412","document_type":""},"filename":"jhta 03 - inv - 1005.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56175   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:09.350 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T12:09:09.350162","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:09.350157","end_time":null,"execution_time":null}
Partition: 0   Offset: 56176   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:09.489 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T12:09:09.489821","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:09.350157","end_time":"2026-03-31T12:09:09.489810","execution_time":0.139653}
Partition: 0   Offset: 56177   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:09.492 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T12:09:09.492168","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:09.492163","end_time":null,"execution_time":null}
Partition: 0   Offset: 56178   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:29.915 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T12:09:29.915435","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:09.492163","end_time":"2026-03-31T12:09:29.915425","execution_time":20.423262}
Partition: 0   Offset: 56179   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:09:29.917 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T12:09:29.917716","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:29.917711","end_time":null,"execution_time":null}
Partition: 0   Offset: 56180   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:03.607 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T12:10:03.607871","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:09:29.917711","end_time":"2026-03-31T12:10:03.607861","execution_time":33.69015}
Partition: 0   Offset: 56181   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:03.610 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T12:10:03.610303","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:10:03.610297","end_time":null,"execution_time":null}
Partition: 0   Offset: 56182   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:30.658 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T12:10:30.658368","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:10:03.610297","end_time":"2026-03-31T12:10:30.658359","execution_time":27.048062}
Partition: 0   Offset: 56183   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:30.660 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T12:10:30.660641","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:10:30.660635","end_time":null,"execution_time":null}
Partition: 0   Offset: 56184   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:30.663 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T12:10:30.663917","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T12:10:30.660635","end_time":"2026-03-31T12:10:30.663908","execution_time":0.003273}
Partition: 0   Offset: 56185   Key: WF_DOCUMENT_6567ddc2   Timestamp: 2026-03-31 12:10:30.670 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_6567ddc2","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T12:10:30.670061","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","file_name":"jhta 03 - inv - 1005.pdf","content_length":191728,"execution_time":81.321357,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":81.3044}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56186   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:23.038 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T13:12:23.038573","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/157b0fb9832d68e56408ab66df5f5f6439e44fcee658f32fcad18ac674fdd3a2.pdf","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"jhta 03 - inv - 1005.pdf","file_type":"application/pdf; name=\"jhta 03 - inv - 1005.pdf\"","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0"}],"subject":"please find this invoice for payment","task_id":"EML_TSK_835894cc","message_id":"19d44053a0b892c6","source":"email-automation-service","uploaded_at":"2026-03-31T13:12:22.997979140Z","sender":"madhawa@redowl.ai","is_updated":true,"grant_id":"85f16bd6-9dc8-4f66-a5d4-2ef1dc1bf088","isTemp":false,"attachment_id":"EML_ATT_7a72c0f0","correlation_id":"EML_WK_b0ab0a70","document_type":""},"filename":"jhta 03 - inv - 1005.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56187   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:23.045 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T13:12:23.044550","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:23.044543","end_time":null,"execution_time":null}
Partition: 0   Offset: 56188   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:23.161 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T13:12:23.161310","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:23.044543","end_time":"2026-03-31T13:12:23.161300","execution_time":0.116757}
Partition: 0   Offset: 56189   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:23.163 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T13:12:23.163134","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:23.163128","end_time":null,"execution_time":null}
Partition: 0   Offset: 56190   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:42.657 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T13:12:42.657532","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:23.163128","end_time":"2026-03-31T13:12:42.657522","execution_time":19.494394}
Partition: 0   Offset: 56191   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:12:42.660 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T13:12:42.659975","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:42.659970","end_time":null,"execution_time":null}
Partition: 0   Offset: 56192   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:12.366 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T13:13:12.366160","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:12:42.659970","end_time":"2026-03-31T13:13:12.366150","execution_time":29.70618}
Partition: 0   Offset: 56193   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:12.369 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T13:13:12.369145","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:13:12.369139","end_time":null,"execution_time":null}
Partition: 0   Offset: 56194   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:38.233 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T13:13:38.233611","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:13:12.369139","end_time":"2026-03-31T13:13:38.233601","execution_time":25.864462}
Partition: 0   Offset: 56195   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:38.236 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T13:13:38.236779","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:13:38.236773","end_time":null,"execution_time":null}
Partition: 0   Offset: 56196   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:38.240 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T13:13:38.240440","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:13:38.236773","end_time":"2026-03-31T13:13:38.240428","execution_time":0.003655}
Partition: 0   Offset: 56197   Key: WF_DOCUMENT_ceca692d   Timestamp: 2026-03-31 13:13:38.258 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_ceca692d","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T13:13:38.258428","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","file_name":"jhta 03 - inv - 1005.pdf","content_length":191728,"execution_time":75.215492,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":75.185448}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56198   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:36.653 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T13:29:36.653271","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/157b0fb9832d68e56408ab66df5f5f6439e44fcee658f32fcad18ac674fdd3a2.pdf","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"jhta 03 - inv - 1005.pdf","file_type":"application/pdf; name=\"jhta 03 - inv - 1005.pdf\"","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0"}],"subject":"proceed this invoice","task_id":"EML_TSK_61dc0690","message_id":"19d4414e4f2317c2","source":"email-automation-service","uploaded_at":"2026-03-31T13:29:36.634525817Z","sender":"madhawa@redowl.ai","is_updated":true,"grant_id":"85f16bd6-9dc8-4f66-a5d4-2ef1dc1bf088","isTemp":false,"attachment_id":"EML_ATT_37d3ca79","correlation_id":"EML_WK_33748f48","document_type":""},"filename":"jhta 03 - inv - 1005.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56199   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:36.656 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T13:29:36.656573","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:36.656566","end_time":null,"execution_time":null}
Partition: 0   Offset: 56200   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:36.827 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T13:29:36.827383","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:36.656566","end_time":"2026-03-31T13:29:36.827373","execution_time":0.170807}
Partition: 0   Offset: 56201   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:36.829 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T13:29:36.829370","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:36.829364","end_time":null,"execution_time":null}
Partition: 0   Offset: 56202   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:54.916 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T13:29:54.916059","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:36.829364","end_time":"2026-03-31T13:29:54.916049","execution_time":18.086685}
Partition: 0   Offset: 56203   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:29:54.919 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T13:29:54.919481","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:54.919476","end_time":null,"execution_time":null}
Partition: 0   Offset: 56204   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:27.173 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T13:30:27.173543","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:29:54.919476","end_time":"2026-03-31T13:30:27.173534","execution_time":32.254058}
Partition: 0   Offset: 56205   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:27.175 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T13:30:27.175837","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:30:27.175832","end_time":null,"execution_time":null}
Partition: 0   Offset: 56206   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:53.817 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T13:30:53.817065","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:30:27.175832","end_time":"2026-03-31T13:30:53.817054","execution_time":26.641222}
Partition: 0   Offset: 56207   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:53.819 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T13:30:53.819673","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:30:53.819667","end_time":null,"execution_time":null}
Partition: 0   Offset: 56208   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:53.824 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T13:30:53.824704","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T13:30:53.819667","end_time":"2026-03-31T13:30:53.824694","execution_time":0.005027}
Partition: 0   Offset: 56209   Key: WF_DOCUMENT_682f3245   Timestamp: 2026-03-31 13:30:53.829 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_682f3245","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T13:30:53.829419","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","file_name":"jhta 03 - inv - 1005.pdf","content_length":191728,"execution_time":77.174324,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":77.157799}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56210   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:03.040 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"WORKFLOW_STARTED","timestamp":"2026-03-31T14:12:03.040302","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","org_code":"JHTAI   ","workflow_type":"email","file_path":"s3://redowl-drive-dev/JHTAI/APF/agent-1/2026-03/157b0fb9832d68e56408ab66df5f5f6439e44fcee658f32fcad18ac674fdd3a2.pdf","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"jhta 03 - inv - 1005.pdf","file_type":"application/pdf; name=\"jhta 03 - inv - 1005.pdf\"","document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0"}],"subject":"invoice process","task_id":"EML_TSK_5fd395d4","message_id":"19d443b60663e085","source":"email-automation-service","uploaded_at":"2026-03-31T14:12:02.907926008Z","sender":"madhawa@redowl.ai","is_updated":true,"grant_id":"85f16bd6-9dc8-4f66-a5d4-2ef1dc1bf088","isTemp":false,"attachment_id":"EML_ATT_7897b7a4","correlation_id":"EML_WK_9ce673ba","document_type":""},"filename":"jhta 03 - inv - 1005.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56211   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:03.045 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-03-31T14:12:03.045540","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:03.045532","end_time":null,"execution_time":null}
Partition: 0   Offset: 56212   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:03.232 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-03-31T14:12:03.232413","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:03.045532","end_time":"2026-03-31T14:12:03.232403","execution_time":0.186871}
Partition: 0   Offset: 56213   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:03.234 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"classification_NODE_STARTED","timestamp":"2026-03-31T14:12:03.234458","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:03.234452","end_time":null,"execution_time":null}
Partition: 0   Offset: 56214   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:20.328 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"classification_NODE_COMPLETED","timestamp":"2026-03-31T14:12:20.328291","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":191728},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:03.234452","end_time":"2026-03-31T14:12:20.328280","execution_time":17.093828}
Partition: 0   Offset: 56215   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:20.330 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-03-31T14:12:20.330882","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:20.330875","end_time":null,"execution_time":null}
Partition: 0   Offset: 56216   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:53.226 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-03-31T14:12:53.226480","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:20.330875","end_time":"2026-03-31T14:12:53.226469","execution_time":32.895594}
Partition: 0   Offset: 56217   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:12:53.229 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-03-31T14:12:53.229451","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:53.229445","end_time":null,"execution_time":null}
Partition: 0   Offset: 56218   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:13:20.152 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-03-31T14:13:20.152922","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:12:53.229445","end_time":"2026-03-31T14:13:20.152912","execution_time":26.923467}
Partition: 0   Offset: 56219   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:13:20.155 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-03-31T14:13:20.155290","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:13:20.155285","end_time":null,"execution_time":null}
Partition: 0   Offset: 56220   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:13:20.157 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-03-31T14:13:20.157865","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","tenant_id":"96b214cf-771d-4243-a340-b14e76bcd04c","workflow_status":"started","start_time":"2026-03-31T14:13:20.155285","end_time":"2026-03-31T14:13:20.157856","execution_time":0.002571}
Partition: 0   Offset: 56221   Key: WF_DOCUMENT_4e068db8   Timestamp: 2026-03-31 14:13:20.172 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_4e068db8","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-03-31T14:13:20.168988","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"4859112a-af6d-4804-8425-f2fe701ba4f0","file_name":"jhta 03 - inv - 1005.pdf","content_length":191728,"execution_time":77.125409,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":77.102331}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56222   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:01:55.453 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-02T05:01:55.453294","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/a72e7a4b232f5bd9262e55b1f1ed432db543e2ae6704fd568589885fa057218a.pdf","document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","email_metadata":{"documents":[{"file_name":"validation_failed.pdf (1).pdf","file_type":"application/pdf; name=\"validation_failed.pdf (1).pdf\"","document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64"}],"subject":"proceeed this invoice for pyment","task_id":"EML_TSK_99dd1e77","message_id":"19d4c901540bcb66","source":"email-automation-service","uploaded_at":"2026-04-02T05:01:55.439206450Z","sender":"madhawa@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_d69dac4d","correlation_id":"EML_WK_75910884","position":"","document_type":""},"filename":"validation_failed.pdf (1).pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56223   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:01:55.457 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-02T05:01:55.457576","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:01:55.457570","end_time":null,"execution_time":null}
Partition: 0   Offset: 56224   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:01:55.614 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-02T05:01:55.614100","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:01:55.457570","end_time":"2026-04-02T05:01:55.614090","execution_time":0.15652}
Partition: 0   Offset: 56225   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:01:55.616 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"classification_NODE_STARTED","timestamp":"2026-04-02T05:01:55.616137","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":57825},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:01:55.616131","end_time":null,"execution_time":null}
Partition: 0   Offset: 56226   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:11.190 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-02T05:02:11.190214","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":57825},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:01:55.616131","end_time":"2026-04-02T05:02:11.190202","execution_time":15.574071}
Partition: 0   Offset: 56227   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:11.192 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-02T05:02:11.192923","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:11.192916","end_time":null,"execution_time":null}
Partition: 0   Offset: 56228   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.881 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-02T05:02:58.881637","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:11.192916","end_time":"2026-04-02T05:02:58.881627","execution_time":47.688711}
Partition: 0   Offset: 56229   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.884 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-02T05:02:58.883988","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:58.883953","end_time":null,"execution_time":null}
Partition: 0   Offset: 56230   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.885 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"validation_and_correction_NODE_FAILED","timestamp":"2026-04-02T05:02:58.885161","node_id":null,"node_name":"validation_and_correction","status":"failed","data":{"reason":"SKIPPED: Skipped OCR correction - data incomplete. Missing required fields: invoice_number, issued_date","document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","is_critical":false,"allow_continuation":true},"error_message":"SKIPPED: Skipped OCR correction - data incomplete. Missing required fields: invoice_number, issued_date","document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56231   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.886 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-02T05:02:58.886673","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:58.883953","end_time":"2026-04-02T05:02:58.886665","execution_time":0.002712}
Partition: 0   Offset: 56232   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.888 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-02T05:02:58.888198","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:58.888192","end_time":null,"execution_time":null}
Partition: 0   Offset: 56233   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.889 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"event_publishing_NODE_FAILED","timestamp":"2026-04-02T05:02:58.889679","node_id":null,"node_name":"event_publishing","status":"failed","data":{"reason":"SKIPPED: Skipped OCR correction - data incomplete. Missing required fields: invoice_number, issued_date","document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","is_critical":false,"allow_continuation":true},"error_message":"SKIPPED: Skipped OCR correction - data incomplete. Missing required fields: invoice_number, issued_date","document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56234   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.895 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-02T05:02:58.895832","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T05:02:58.888192","end_time":"2026-04-02T05:02:58.895813","execution_time":0.007621}
Partition: 0   Offset: 56235   Key: WF_DOCUMENT_bdf16c2f   Timestamp: 2026-04-02 05:02:58.902 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_bdf16c2f","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-02T05:02:58.902185","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"327f24ac-c1d9-4f8d-86f2-a3bd4212ee64","file_name":"validation_failed.pdf (1).pdf","content_length":57825,"execution_time":63.446639,"error_count":4,"final_status":"completed_with_warnings","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":63.429635000000005}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56236   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:38:50.349 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-02T11:38:50.349226","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/3ddff24370c44251f96da42ebcfb83e6b6f2ba11aa490b8296bb8cb1b7c202b3.pdf","document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","email_metadata":{"documents":[{"file_name":"Sc-01.pdf","file_type":"application/pdf; name=\"Sc-01.pdf\"","document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a"}],"subject":"please check this invoice","task_id":"EML_TSK_f6476146","message_id":"19d4dfbb1dd66129","source":"email-automation-service","uploaded_at":"2026-04-02T11:38:50.311267913Z","sender":"madhawa@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_68014b03","correlation_id":"EML_WK_acca0195","position":"","document_type":""},"filename":"Sc-01.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56237   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:38:50.353 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-02T11:38:50.353789","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:38:50.353783","end_time":null,"execution_time":null}
Partition: 0   Offset: 56238   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:38:50.441 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-02T11:38:50.441221","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:38:50.353783","end_time":"2026-04-02T11:38:50.441211","execution_time":0.087428}
Partition: 0   Offset: 56239   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:38:50.443 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"classification_NODE_STARTED","timestamp":"2026-04-02T11:38:50.443734","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":431093},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:38:50.443729","end_time":null,"execution_time":null}
Partition: 0   Offset: 56240   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:39:06.854 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-02T11:39:06.854198","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":431093},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:38:50.443729","end_time":"2026-04-02T11:39:06.854189","execution_time":16.41046}
Partition: 0   Offset: 56241   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:39:06.856 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-02T11:39:06.856511","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:39:06.856505","end_time":null,"execution_time":null}
Partition: 0   Offset: 56242   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:39:37.442 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-02T11:39:37.442025","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:39:06.856505","end_time":"2026-04-02T11:39:37.442015","execution_time":30.58551}
Partition: 0   Offset: 56243   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:39:37.444 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-02T11:39:37.444668","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:39:37.444662","end_time":null,"execution_time":null}
Partition: 0   Offset: 56244   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:40:02.359 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-02T11:40:02.359585","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:39:37.444662","end_time":"2026-04-02T11:40:02.359575","execution_time":24.914913}
Partition: 0   Offset: 56245   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:40:02.362 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-02T11:40:02.361997","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:40:02.361991","end_time":null,"execution_time":null}
Partition: 0   Offset: 56246   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:40:02.367 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-02T11:40:02.367388","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-02T11:40:02.361991","end_time":"2026-04-02T11:40:02.367377","execution_time":0.005386}
Partition: 0   Offset: 56247   Key: WF_DOCUMENT_2464dd58   Timestamp: 2026-04-02 11:40:02.370 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_2464dd58","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-02T11:40:02.370315","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"5c7f1634-1034-4a8e-aa16-2102fad28c8a","file_name":"Sc-01.pdf","content_length":431093,"execution_time":72.018492,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":72.003697}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56248   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:12:21.971 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-06T04:12:21.971344","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/95a5d8f0b1bada045dd54017dc35490a80d8125c45902407e74f7341cf9c3a86.pdf","document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"uj 29 sct.pdf","file_type":"application/pdf; name=\"UJ 29 SCT.pdf\"","document_id":"875397a5-a4f8-452a-b350-91b25ee939cd"}],"subject":"please proceed this invoice","task_id":"EML_TSK_8e24946e","message_id":"19d60fd5bba7cfae","source":"email-automation-service","uploaded_at":"2026-04-06T04:12:21.960288093Z","sender":"madhawa@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_8b3eea56","correlation_id":"EML_WK_ac22483d","document_type":""},"filename":"uj 29 sct.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56249   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:12:21.974 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-06T04:12:21.974814","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T04:12:21.974808","end_time":null,"execution_time":null}
Partition: 0   Offset: 56255   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:13:13.375 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-06T04:13:13.375009","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T04:13:13.375003","end_time":null,"execution_time":null}
Partition: 0   Offset: 56256   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:13:39.884 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-06T04:13:39.884159","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T04:13:13.375003","end_time":"2026-04-06T04:13:39.884148","execution_time":26.509145}
Partition: 0   Offset: 56257   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:13:39.887 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-06T04:13:39.887342","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T04:13:39.887336","end_time":null,"execution_time":null}
Partition: 0   Offset: 56258   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:13:39.937 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-06T04:13:39.936977","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T04:13:39.887336","end_time":"2026-04-06T04:13:39.936964","execution_time":0.049628}
Partition: 0   Offset: 56259   Key: WF_DOCUMENT_0ff2b47b   Timestamp: 2026-04-06 04:13:39.954 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_0ff2b47b","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-06T04:13:39.954920","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"875397a5-a4f8-452a-b350-91b25ee939cd","file_name":"uj 29 sct.pdf","content_length":42666,"execution_time":77.981463,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":77.950236}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56260   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:43.638 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-06T11:27:43.638847","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/d6a886769f7681ef34aa4e3fe3b80c14518697a6051bba2163327699327484e1.pdf","document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"invoice inv-1025.pdf","file_type":"application/pdf; name=\"Invoice INV-1025.pdf\"","document_id":"fa62e170-e525-4de5-8286-8f2690fa788a"}],"subject":"proceeeed this invoice for payment","task_id":"EML_TSK_ff908950","message_id":"19d628b8ca8929bf","source":"email-automation-service","uploaded_at":"2026-04-06T11:27:43.568455229Z","sender":"madhawa@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_a983648c","correlation_id":"EML_WK_152226c0","document_type":""},"filename":"invoice inv-1025.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56261   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:43.644 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-06T11:27:43.644135","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:43.644128","end_time":null,"execution_time":null}
Partition: 0   Offset: 56262   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:43.722 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-06T11:27:43.721982","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:43.644128","end_time":"2026-04-06T11:27:43.721971","execution_time":0.077843}
Partition: 0   Offset: 56263   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:43.725 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"classification_NODE_STARTED","timestamp":"2026-04-06T11:27:43.725086","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":108635},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:43.725080","end_time":null,"execution_time":null}
Partition: 0   Offset: 56264   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:59.663 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-06T11:27:59.663535","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":108635},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:43.725080","end_time":"2026-04-06T11:27:59.663526","execution_time":15.938446}
Partition: 0   Offset: 56265   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:27:59.667 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-06T11:27:59.667533","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:59.667527","end_time":null,"execution_time":null}
Partition: 0   Offset: 56266   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:28:32.349 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-06T11:28:32.349885","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:27:59.667527","end_time":"2026-04-06T11:28:32.349875","execution_time":32.682348}
Partition: 0   Offset: 56267   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:28:32.352 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-06T11:28:32.352289","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:28:32.352284","end_time":null,"execution_time":null}
Partition: 0   Offset: 56268   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:29:00.777 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-06T11:29:00.777465","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:28:32.352284","end_time":"2026-04-06T11:29:00.777455","execution_time":28.425171}
Partition: 0   Offset: 56269   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:29:00.780 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-06T11:29:00.780637","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:29:00.780631","end_time":null,"execution_time":null}
Partition: 0   Offset: 56270   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:29:00.792 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-06T11:29:00.792103","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T11:29:00.780631","end_time":"2026-04-06T11:29:00.792090","execution_time":0.011459}
Partition: 0   Offset: 56271   Key: WF_DOCUMENT_50f40f41   Timestamp: 2026-04-06 11:29:00.798 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_50f40f41","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-06T11:29:00.797975","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"fa62e170-e525-4de5-8286-8f2690fa788a","file_name":"invoice inv-1025.pdf","content_length":108635,"execution_time":77.156493,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":77.135267}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56272   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:28.118 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-06T12:05:28.118485","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii invoice.pdf","file_type":"application/pdf; name=\"Doshii Invoice.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"please procceeed this invoice","task_id":"EML_TSK_b0fad214","message_id":"19d62ae6957621fd","source":"email-automation-service","uploaded_at":"2026-04-06T12:05:28.105547137Z","sender":"madhawa@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_c826ea83","correlation_id":"EML_WK_3050b00d","document_type":""},"filename":"doshii invoice.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56273   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:28.123 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-06T12:05:28.123017","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:28.123010","end_time":null,"execution_time":null}
Partition: 0   Offset: 56274   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:28.196 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-06T12:05:28.196411","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:28.123010","end_time":"2026-04-06T12:05:28.196400","execution_time":0.07339}
Partition: 0   Offset: 56275   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:28.198 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"classification_NODE_STARTED","timestamp":"2026-04-06T12:05:28.198103","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:28.198097","end_time":null,"execution_time":null}
Partition: 0   Offset: 56276   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:42.816 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-06T12:05:42.816401","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:28.198097","end_time":"2026-04-06T12:05:42.816391","execution_time":14.618294}
Partition: 0   Offset: 56277   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:05:42.819 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-06T12:05:42.819061","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:42.819055","end_time":null,"execution_time":null}
Partition: 0   Offset: 56278   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:07:04.064 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-06T12:07:04.063985","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:05:42.819055","end_time":"2026-04-06T12:07:04.063973","execution_time":81.244918}
Partition: 0   Offset: 56279   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:07:04.067 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-06T12:07:04.067794","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:07:04.067788","end_time":null,"execution_time":null}
Partition: 0   Offset: 56280   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:08:10.471 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-06T12:08:10.471197","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:07:04.067788","end_time":"2026-04-06T12:08:10.471188","execution_time":66.4034}
Partition: 0   Offset: 56281   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:08:10.474 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-06T12:08:10.474041","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:08:10.474035","end_time":null,"execution_time":null}
Partition: 0   Offset: 56282   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:08:10.477 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-06T12:08:10.477924","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-06T12:08:10.474035","end_time":"2026-04-06T12:08:10.477914","execution_time":0.003879}
Partition: 0   Offset: 56283   Key: WF_DOCUMENT_cedce5c7   Timestamp: 2026-04-06 12:08:10.497 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_cedce5c7","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-06T12:08:10.497044","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"doshii invoice.pdf","content_length":61761,"execution_time":162.376311,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":162.343881}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56284   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:04.715 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T09:43:04.715801","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii inv.pdf","file_type":"application/pdf; name=\"Doshii inv.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"Invoice Submission","task_id":"EML_TSK_6ef2ca84","message_id":"19d6c789de415a6e","source":"email-automation-service","uploaded_at":"2026-04-08T09:43:04.699048663Z","sender":"yasinda@redowl.ai","is_updated":true,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_cbfb69ca","correlation_id":"EML_WK_2d2c5d91","document_type":""},"filename":"doshii inv.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56285   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:04.722 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T09:43:04.721994","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:04.721987","end_time":null,"execution_time":null}
Partition: 0   Offset: 56286   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:04.859 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T09:43:04.859794","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:04.721987","end_time":"2026-04-08T09:43:04.859783","execution_time":0.137796}
Partition: 0   Offset: 56287   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:04.861 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T09:43:04.861498","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:04.861492","end_time":null,"execution_time":null}
Partition: 0   Offset: 56288   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:47.982 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T09:43:47.982218","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:04.861492","end_time":"2026-04-08T09:43:47.982208","execution_time":43.120716}
Partition: 0   Offset: 56289   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:43:47.985 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T09:43:47.985686","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:47.985680","end_time":null,"execution_time":null}
Partition: 0   Offset: 56290   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:45:16.044 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T09:45:16.044537","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:43:47.985680","end_time":"2026-04-08T09:45:16.044526","execution_time":88.058846}
Partition: 0   Offset: 56291   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:45:16.047 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T09:45:16.047857","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:45:16.047850","end_time":null,"execution_time":null}
Partition: 0   Offset: 56292   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:46:41.488 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T09:46:41.488326","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:45:16.047850","end_time":"2026-04-08T09:46:41.488316","execution_time":85.440466}
Partition: 0   Offset: 56293   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:46:41.491 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T09:46:41.491344","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:46:41.491339","end_time":null,"execution_time":null}
Partition: 0   Offset: 56294   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:46:41.514 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T09:46:41.514747","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T09:46:41.491339","end_time":"2026-04-08T09:46:41.514736","execution_time":0.023397}
Partition: 0   Offset: 56295   Key: WF_DOCUMENT_9ca07d03   Timestamp: 2026-04-08 09:46:41.517 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9ca07d03","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T09:46:41.517622","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"doshii inv.pdf","content_length":61761,"execution_time":216.797325,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":216.78122100000002}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56296   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:08:30.348 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T10:08:30.348259","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"documents":[{"file_name":"Doshii inv.pdf","file_type":"application/pdf; name=\"Doshii inv.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"Invoice Payment","task_id":"EML_TSK_42a8fbe1","message_id":"19d6c6ab4580178e","source":"email-automation-service","uploaded_at":"2026-04-08T10:08:30.333080436Z","sender":"johanfernando.96@gmail.com","is_updated":true,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_b7fe47d1","correlation_id":"EML_WK_83b43702","position":"","document_type":""},"filename":"Doshii inv.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56297   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:08:30.353 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T10:08:30.353045","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:08:30.353038","end_time":null,"execution_time":null}
Partition: 0   Offset: 56298   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:08:30.482 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T10:08:30.482063","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:08:30.353038","end_time":"2026-04-08T10:08:30.482052","execution_time":0.129014}
Partition: 0   Offset: 56299   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:08:30.483 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T10:08:30.483922","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:08:30.483917","end_time":null,"execution_time":null}
Partition: 0   Offset: 56300   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:09:01.833 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T10:09:01.833145","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:08:30.483917","end_time":"2026-04-08T10:09:01.833135","execution_time":31.349218}
Partition: 0   Offset: 56301   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:09:01.836 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T10:09:01.836510","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:09:01.836504","end_time":null,"execution_time":null}
Partition: 0   Offset: 56302   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:10:19.930 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T10:10:19.930108","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:09:01.836504","end_time":"2026-04-08T10:10:19.930098","execution_time":78.093594}
Partition: 0   Offset: 56303   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:10:19.933 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T10:10:19.932951","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:10:19.932946","end_time":null,"execution_time":null}
Partition: 0   Offset: 56304   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:11:30.460 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T10:11:30.460449","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:10:19.932946","end_time":"2026-04-08T10:11:30.460439","execution_time":70.527493}
Partition: 0   Offset: 56305   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:11:30.463 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T10:11:30.463088","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:11:30.463082","end_time":null,"execution_time":null}
Partition: 0   Offset: 56306   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:11:30.467 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T10:11:30.467377","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:11:30.463082","end_time":"2026-04-08T10:11:30.467366","execution_time":0.004284}
Partition: 0   Offset: 56307   Key: WF_DOCUMENT_f66615cc   Timestamp: 2026-04-08 10:11:30.490 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_f66615cc","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T10:11:30.489957","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"Doshii inv.pdf","content_length":61761,"execution_time":180.139073,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":180.10360300000002}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56308   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:07.943 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T10:29:07.943884","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii inv.pdf","file_type":"application/pdf; name=\"Doshii inv.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"Invoice Payment - April","task_id":"EML_TSK_f054b916","message_id":"19d6ca304ffd831d","source":"email-automation-service","uploaded_at":"2026-04-08T10:29:07.906504844Z","sender":"Johan@redowl.ai","is_updated":true,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_8c274c35","correlation_id":"EML_WK_3843227e","document_type":""},"filename":"doshii inv.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56309   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:07.948 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T10:29:07.948037","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:07.948030","end_time":null,"execution_time":null}
Partition: 0   Offset: 56310   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:08.073 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T10:29:08.073635","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:07.948030","end_time":"2026-04-08T10:29:08.073624","execution_time":0.125594}
Partition: 0   Offset: 56311   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:08.076 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T10:29:08.076008","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:08.076002","end_time":null,"execution_time":null}
Partition: 0   Offset: 56312   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:21.950 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T10:29:21.950483","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:08.076002","end_time":"2026-04-08T10:29:21.950474","execution_time":13.874472}
Partition: 0   Offset: 56313   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:29:21.954 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T10:29:21.954172","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:21.954167","end_time":null,"execution_time":null}
Partition: 0   Offset: 56314   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:30:37.378 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T10:30:37.378770","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:29:21.954167","end_time":"2026-04-08T10:30:37.378759","execution_time":75.424592}
Partition: 0   Offset: 56315   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:30:37.381 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T10:30:37.381525","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:30:37.381519","end_time":null,"execution_time":null}
Partition: 0   Offset: 56316   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:31:46.329 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T10:31:46.328938","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:30:37.381519","end_time":"2026-04-08T10:31:46.328928","execution_time":68.947409}
Partition: 0   Offset: 56317   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:31:46.332 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T10:31:46.331959","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:31:46.331953","end_time":null,"execution_time":null}
Partition: 0   Offset: 56318   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:31:46.336 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T10:31:46.336865","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:31:46.331953","end_time":"2026-04-08T10:31:46.336855","execution_time":0.004902}
Partition: 0   Offset: 56319   Key: WF_DOCUMENT_422c6272   Timestamp: 2026-04-08 10:31:46.355 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_422c6272","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T10:31:46.355299","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"doshii inv.pdf","content_length":61761,"execution_time":158.409184,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":158.376969}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56320   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:21.225 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T10:51:21.225588","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii inv.pdf","file_type":"application/pdf; name=\"Doshii inv.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"Invoice Submission - INV 0804223","task_id":"EML_TSK_ad3aa9ed","message_id":"19d6cb72acf6e37c","source":"email-automation-service","uploaded_at":"2026-04-08T10:51:21.210479750Z","sender":"yasinda@redowl.ai","is_updated":true,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_7adcca42","correlation_id":"EML_WK_6988a091","document_type":""},"filename":"doshii inv.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56321   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:21.229 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T10:51:21.229344","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:21.229338","end_time":null,"execution_time":null}
Partition: 0   Offset: 56322   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:21.325 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T10:51:21.325040","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:21.229338","end_time":"2026-04-08T10:51:21.325029","execution_time":0.095691}
Partition: 0   Offset: 56323   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:21.327 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T10:51:21.327504","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:21.327498","end_time":null,"execution_time":null}
Partition: 0   Offset: 56324   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:36.793 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T10:51:36.793825","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:21.327498","end_time":"2026-04-08T10:51:36.793816","execution_time":15.466318}
Partition: 0   Offset: 56325   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:51:36.796 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T10:51:36.796696","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:36.796691","end_time":null,"execution_time":null}
Partition: 0   Offset: 56326   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:52:51.555 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T10:52:51.555330","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:51:36.796691","end_time":"2026-04-08T10:52:51.555319","execution_time":74.758628}
Partition: 0   Offset: 56327   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:52:51.558 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T10:52:51.557949","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:52:51.557943","end_time":null,"execution_time":null}
Partition: 0   Offset: 56328   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:54:02.560 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T10:54:02.560603","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:52:51.557943","end_time":"2026-04-08T10:54:02.560593","execution_time":71.00265}
Partition: 0   Offset: 56329   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:54:02.563 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T10:54:02.563357","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:54:02.563352","end_time":null,"execution_time":null}
Partition: 0   Offset: 56330   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:54:02.585 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T10:54:02.585862","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T10:54:02.563352","end_time":"2026-04-08T10:54:02.585850","execution_time":0.022498}
Partition: 0   Offset: 56331   Key: WF_DOCUMENT_148e5e6b   Timestamp: 2026-04-08 10:54:02.605 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_148e5e6b","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T10:54:02.605758","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"doshii inv.pdf","content_length":61761,"execution_time":161.378194,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":161.345785}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56332   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:53:45.519 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T12:53:45.519525","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/649d732b7d248a1a0cc35121c8f69adf6681e7989dfe1b34cd768471c90a15ba.pdf","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii inv.pdf","file_type":"application/pdf; name=\"Doshii inv.pdf\"","document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf"}],"subject":"Invoice Submission INV 123322","task_id":"EML_TSK_efa8b964","message_id":"19d6d2772e1caff3","source":"email-automation-service","uploaded_at":"2026-04-08T12:53:45.504849100Z","sender":"yasinda@redowl.ai","is_updated":true,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_2bce9636","correlation_id":"EML_WK_1dbae3ab","document_type":""},"filename":"doshii inv.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56333   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:53:45.523 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T12:53:45.523088","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:53:45.523082","end_time":null,"execution_time":null}
Partition: 0   Offset: 56334   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:53:45.653 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T12:53:45.652951","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:53:45.523082","end_time":"2026-04-08T12:53:45.652940","execution_time":0.129858}
Partition: 0   Offset: 56335   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:53:45.654 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T12:53:45.654843","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:53:45.654837","end_time":null,"execution_time":null}
Partition: 0   Offset: 56336   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:54:05.168 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T12:54:05.168544","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61761},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:53:45.654837","end_time":"2026-04-08T12:54:05.168534","execution_time":19.513697}
Partition: 0   Offset: 56337   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:54:05.170 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T12:54:05.170913","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:54:05.170907","end_time":null,"execution_time":null}
Partition: 0   Offset: 56338   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:55:22.576 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T12:55:22.576455","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:54:05.170907","end_time":"2026-04-08T12:55:22.576445","execution_time":77.405538}
Partition: 0   Offset: 56339   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:55:22.580 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T12:55:22.580012","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:55:22.580006","end_time":null,"execution_time":null}
Partition: 0   Offset: 56340   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:56:30.310 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T12:56:30.310495","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:55:22.580006","end_time":"2026-04-08T12:56:30.310483","execution_time":67.730477}
Partition: 0   Offset: 56341   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:56:30.313 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T12:56:30.313592","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:56:30.313585","end_time":null,"execution_time":null}
Partition: 0   Offset: 56342   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:56:30.335 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T12:56:30.334932","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T12:56:30.313585","end_time":"2026-04-08T12:56:30.334920","execution_time":0.021335}
Partition: 0   Offset: 56343   Key: WF_DOCUMENT_9fdeae04   Timestamp: 2026-04-08 12:56:30.339 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_9fdeae04","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T12:56:30.339221","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"ee0c5142-8765-49ef-98aa-1e59aaae55cf","file_name":"doshii inv.pdf","content_length":61761,"execution_time":164.81785,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":164.80090499999997}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56344   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:06.573 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"WORKFLOW_STARTED","timestamp":"2026-04-08T13:11:06.573118","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","org_code":"SOUTHERN","workflow_type":"email","file_path":"s3://redowl-drive-dev/SOUTHERN/APF/agent-1/2026-04/06938d5b9382c760d429f461a7011a7e1784ddb24ab8742d60787ff4ff260a64.pdf","document_id":"409770c0-17f4-4510-81ff-7f9205c45538","email_metadata":{"executive_workflow":false,"documents":[{"file_name":"doshii inv2.pdf","file_type":"application/pdf; name=\"Doshii inv2.pdf\"","document_id":"409770c0-17f4-4510-81ff-7f9205c45538"}],"subject":"Invoice Submission - INV23342","task_id":"EML_TSK_bdfca172","message_id":"19d6d36c97bbb599","source":"email-automation-service","uploaded_at":"2026-04-08T13:11:06.560110712Z","sender":"yasinda@redowl.ai","is_updated":false,"grant_id":"f83c71d8-adeb-473b-9b9f-21edf2e721ad","isTemp":false,"attachment_id":"EML_ATT_a3f29e9d","correlation_id":"EML_WK_6c61e1cc","document_type":""},"filename":"doshii inv2.pdf"},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 56345   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:06.577 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"document_retrieve_NODE_STARTED","timestamp":"2026-04-08T13:11:06.576963","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:06.576957","end_time":null,"execution_time":null}
Partition: 0   Offset: 56346   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:06.661 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2026-04-08T13:11:06.661578","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:06.576957","end_time":"2026-04-08T13:11:06.661568","execution_time":0.084611}
Partition: 0   Offset: 56347   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:06.664 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"classification_NODE_STARTED","timestamp":"2026-04-08T13:11:06.664053","node_id":null,"node_name":"classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":224542},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:06.664045","end_time":null,"execution_time":null}
Partition: 0   Offset: 56348   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:24.432 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"classification_NODE_COMPLETED","timestamp":"2026-04-08T13:11:24.432851","node_id":null,"node_name":"classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":224542},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:06.664045","end_time":"2026-04-08T13:11:24.432841","execution_time":17.768796}
Partition: 0   Offset: 56349   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:11:24.436 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"data_extraction_NODE_STARTED","timestamp":"2026-04-08T13:11:24.436278","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:24.436273","end_time":null,"execution_time":null}
Partition: 0   Offset: 56350   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:12:44.779 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2026-04-08T13:12:44.779228","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:11:24.436273","end_time":"2026-04-08T13:12:44.779217","execution_time":80.342944}
Partition: 0   Offset: 56351   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:12:44.782 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2026-04-08T13:12:44.782016","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:12:44.782010","end_time":null,"execution_time":null}
Partition: 0   Offset: 56352   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:13:52.991 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2026-04-08T13:13:52.991063","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:12:44.782010","end_time":"2026-04-08T13:13:52.991051","execution_time":68.209041}
Partition: 0   Offset: 56353   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:13:52.994 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"event_publishing_NODE_STARTED","timestamp":"2026-04-08T13:13:52.994037","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:13:52.994031","end_time":null,"execution_time":null}
Partition: 0   Offset: 56354   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:13:52.998 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2026-04-08T13:13:52.998320","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","tenant_id":"c372b8c4-6233-4b2b-b48b-f9b044abcaba","workflow_status":"started","start_time":"2026-04-08T13:13:52.994031","end_time":"2026-04-08T13:13:52.998309","execution_time":0.004278}
Partition: 0   Offset: 56355   Key: WF_DOCUMENT_743e06da   Timestamp: 2026-04-08 13:13:53.027 Headers: empty
 
{"doc_workflow_id":"WF_DOCUMENT_743e06da","event_type":"WORKFLOW_COMPLETED","timestamp":"2026-04-08T13:13:53.027611","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"409770c0-17f4-4510-81ff-7f9205c45538","file_name":"doshii inv2.pdf","content_length":224542,"execution_time":166.452073,"error_count":0,"final_status":"success","nodes_summary":{"total_nodes":5,"completed":5,"failed":0,"in_progress":0,"total_nodes_execution_time":166.40967}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}