Topic Messages: dev.workflow.monitoring

Partition: 0   Offset: 7711   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:02.377 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T06:25:02.377753","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-15/2025-11/764719560dc3d6f00267313f55d68713a8fb4682dee0813a7e4dd4dc61146943.pdf","document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","email_metadata":{"uploaded_at":"2025-11-04T06:25:02.353256892Z","sender":"madhawa@redowl.ai","is_updated":false,"documents":[{"file_name":"1.4.2(ct-inv-50-1025).pdf","file_type":"application/pdf; name=\"1.4.2(CT-INV-50-1025).pdf\"","document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39"},{"file_name":"harbourbridge inv-1003.pdf","file_type":"application/pdf; name=\"Harbourbridge INV-1003.pdf\"","document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e"}],"subject":"check this invoice","grant_id":"5dc1b0d2-c708-4376-81ba-62c6acb6842d","attachment_id":506,"task_id":466,"message_id":"19a4d8a272dc6cae","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7712   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:02.386 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T06:25:02.386111","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.386104","end_time":null,"execution_time":null}
Partition: 0   Offset: 7713   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:02.395 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T06:25:02.395208","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-15/2025-11/d412650240a4fdaac3f2759068ebb3fe9b2bca06407740a6cd8dad4146a42e89.pdf","document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","email_metadata":{"uploaded_at":"2025-11-04T06:25:02.353818527Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"1.4.2(ct-inv-50-1025).pdf","file_type":"application/pdf; name=\"1.4.2(CT-INV-50-1025).pdf\"","document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39"},{"file_name":"harbourbridge inv-1003.pdf","file_type":"application/pdf; name=\"Harbourbridge INV-1003.pdf\"","document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e"}],"subject":"check this invoice","grant_id":"5dc1b0d2-c708-4376-81ba-62c6acb6842d","attachment_id":505,"task_id":466,"message_id":"19a4d8a272dc6cae","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7714   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:02.402 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T06:25:02.402476","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.402470","end_time":null,"execution_time":null}
Partition: 0   Offset: 7715   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:02.469 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T06:25:02.469226","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.386104","end_time":"2025-11-04T06:25:02.469214","execution_time":0.08311}
Partition: 0   Offset: 7716   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:02.470 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T06:25:02.470742","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":302541},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.470737","end_time":null,"execution_time":null}
Partition: 0   Offset: 7717   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:02.649 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T06:25:02.649238","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.402470","end_time":"2025-11-04T06:25:02.649224","execution_time":0.246754}
Partition: 0   Offset: 7718   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:02.651 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T06:25:02.650912","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":65869},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.650906","end_time":null,"execution_time":null}
Partition: 0   Offset: 7719   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:16.100 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T06:25:16.100338","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":65869},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.650906","end_time":"2025-11-04T06:25:16.100328","execution_time":13.449422}
Partition: 0   Offset: 7720   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:16.101 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T06:25:16.101736","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:16.101732","end_time":null,"execution_time":null}
Partition: 0   Offset: 7721   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:17.634 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T06:25:17.634833","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":302541},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:02.470737","end_time":"2025-11-04T06:25:17.634823","execution_time":15.164086}
Partition: 0   Offset: 7722   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:25:17.636 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T06:25:17.636459","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:17.636454","end_time":null,"execution_time":null}
Partition: 0   Offset: 7723   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:43.584 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T06:25:43.584865","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:16.101732","end_time":"2025-11-04T06:25:43.584856","execution_time":27.483124}
Partition: 0   Offset: 7724   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:25:43.587 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T06:25:43.587767","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:43.587762","end_time":null,"execution_time":null}
Partition: 0   Offset: 7725   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.205 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.205226","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:43.587762","end_time":"2025-11-04T06:26:05.205216","execution_time":21.617454}
Partition: 0   Offset: 7726   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.207 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T06:26:05.207524","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.207519","end_time":null,"execution_time":null}
Partition: 0   Offset: 7727   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.211 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.211623","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.207519","end_time":"2025-11-04T06:26:05.211612","execution_time":0.004093}
Partition: 0   Offset: 7728   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.220 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T06:26:05.220081","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.220075","end_time":null,"execution_time":null}
Partition: 0   Offset: 7729   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.222 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.222820","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.220075","end_time":"2025-11-04T06:26:05.222809","execution_time":0.002734}
Partition: 0   Offset: 7730   Key: wf_email_321cb96e   Timestamp: 2025-11-04 06:26:05.227 Headers: empty
  
{"doc_workflow_id":"wf_email_321cb96e","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T06:26:05.227889","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"3ee492d8-51fd-4754-9ab7-39c4a518ee39","file_name":"harbourbridge inv-1003.pdf","content_length":0,"execution_time":62.827017,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":62.80358099999999}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7731   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.466 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.466713","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:25:17.636454","end_time":"2025-11-04T06:26:05.466703","execution_time":47.830249}
Partition: 0   Offset: 7732   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.469 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T06:26:05.469022","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.469017","end_time":null,"execution_time":null}
Partition: 0   Offset: 7733   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.470 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"validation_and_correction_NODE_FAILED","timestamp":"2025-11-04T06:26:05.470297","node_id":null,"node_name":"validation_and_correction","status":"failed","data":{"reason":"Skipped OCR correction - data incomplete. Missing required fields: total_amount","document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73"},"error_message":"Skipped OCR correction - data incomplete. Missing required fields: total_amount","document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7734   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.471 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.471777","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.469017","end_time":"2025-11-04T06:26:05.471770","execution_time":0.002753}
Partition: 0   Offset: 7735   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.473 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T06:26:05.473374","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.473369","end_time":null,"execution_time":null}
Partition: 0   Offset: 7736   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.474 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"event publishing_NODE_FAILED","timestamp":"2025-11-04T06:26:05.474634","node_id":null,"node_name":"event publishing","status":"failed","data":{"reason":"Skipped due to validation failure","document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73"},"error_message":"Skipped due to validation failure","document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7737   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.477 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.477041","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.473369","end_time":"2025-11-04T06:26:05.477032","execution_time":0.003663}
Partition: 0   Offset: 7738   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.481 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T06:26:05.480933","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.480927","end_time":null,"execution_time":null}
Partition: 0   Offset: 7739   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.484 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T06:26:05.484694","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:26:05.480927","end_time":"2025-11-04T06:26:05.484684","execution_time":0.003757}
Partition: 0   Offset: 7740   Key: wf_email_91077e4b   Timestamp: 2025-11-04 06:26:05.494 Headers: empty
  
{"doc_workflow_id":"wf_email_91077e4b","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T06:26:05.494199","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"8f0964f1-5bb2-4d12-97c3-e6fad6ad333e","file_name":"1.4.2(ct-inv-50-1025).pdf","content_length":0,"execution_time":63.109686,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":63.087618}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7741   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:30:57.630 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T06:30:57.630446","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-15/2025-11/d400cb729107ce018aa5e84322d8bd72c54260c43ad6c5cedbe915be997ab7ae.pdf","document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","email_metadata":{"uploaded_at":"2025-11-04T06:30:57.614454554Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"3.pdf","file_type":"application/pdf; name=\"3.pdf\"","document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b"}],"subject":"process these attachment","grant_id":"5dc1b0d2-c708-4376-81ba-62c6acb6842d","attachment_id":507,"task_id":467,"message_id":"19a4d8f98aec9cb0","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7742   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:30:57.633 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T06:30:57.633884","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:30:57.633879","end_time":null,"execution_time":null}
Partition: 0   Offset: 7743   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:30:57.692 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T06:30:57.692719","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:30:57.633879","end_time":"2025-11-04T06:30:57.692708","execution_time":0.058829}
Partition: 0   Offset: 7744   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:30:57.694 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T06:30:57.694152","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":62219},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:30:57.694146","end_time":null,"execution_time":null}
Partition: 0   Offset: 7745   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:31:13.211 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T06:31:13.211686","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":62219},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:30:57.694146","end_time":"2025-11-04T06:31:13.211676","execution_time":15.51753}
Partition: 0   Offset: 7746   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:31:13.214 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T06:31:13.214602","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:31:13.214597","end_time":null,"execution_time":null}
Partition: 0   Offset: 7747   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:31:36.576 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T06:31:36.576146","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:31:13.214597","end_time":"2025-11-04T06:31:36.576137","execution_time":23.36154}
Partition: 0   Offset: 7748   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:31:36.577 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T06:31:36.577893","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:31:36.577888","end_time":null,"execution_time":null}
Partition: 0   Offset: 7749   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.044 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T06:32:09.044467","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:31:36.577888","end_time":"2025-11-04T06:32:09.044457","execution_time":32.466569}
Partition: 0   Offset: 7750   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.046 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T06:32:09.046278","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:32:09.046274","end_time":null,"execution_time":null}
Partition: 0   Offset: 7751   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.049 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T06:32:09.049056","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:32:09.046274","end_time":"2025-11-04T06:32:09.049047","execution_time":0.002773}
Partition: 0   Offset: 7752   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.055 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T06:32:09.055874","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:32:09.055868","end_time":null,"execution_time":null}
Partition: 0   Offset: 7753   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.058 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T06:32:09.058289","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T06:32:09.055868","end_time":"2025-11-04T06:32:09.058278","execution_time":0.00241}
Partition: 0   Offset: 7754   Key: wf_email_1e73f3bd   Timestamp: 2025-11-04 06:32:09.062 Headers: empty
  
{"doc_workflow_id":"wf_email_1e73f3bd","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T06:32:09.062376","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"0c9e42f7-11ff-47bb-b26f-a53c24c8125b","file_name":"3.pdf","content_length":0,"execution_time":71.429633,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":71.40965100000001}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7755   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:06.740 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T10:19:06.740052","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/078f66d2a102d2dc61b7e759ca2f9aadb1d3930d2d5de3762c9012bcad88a75b.pdf","document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","email_metadata":{"uploaded_at":"2025-11-04T10:19:06.720345493Z","sender":"madhawa@redowl.ai","is_updated":false,"documents":[{"file_name":"cleanco inv-1006.pdf","file_type":"application/pdf; name=\"CleanCo INV-1006.pdf\"","document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1"}],"subject":"invoice number 123-123","grant_id":"05d626c6-81ff-45b3-ba06-8c9fb4e5b2cd","attachment_id":508,"task_id":486,"message_id":"19a4e60785ad2414","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7756   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:06.743 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T10:19:06.743330","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:06.743324","end_time":null,"execution_time":null}
Partition: 0   Offset: 7757   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:06.807 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T10:19:06.807246","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:06.743324","end_time":"2025-11-04T10:19:06.807235","execution_time":0.063911}
Partition: 0   Offset: 7758   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:06.808 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T10:19:06.808878","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":64802},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:06.808873","end_time":null,"execution_time":null}
Partition: 0   Offset: 7759   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:22.697 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T10:19:22.696942","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":64802},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:06.808873","end_time":"2025-11-04T10:19:22.696932","execution_time":15.888059}
Partition: 0   Offset: 7760   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:22.698 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T10:19:22.698876","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:22.698871","end_time":null,"execution_time":null}
Partition: 0   Offset: 7761   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:43.321 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T10:19:43.321712","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:22.698871","end_time":"2025-11-04T10:19:43.321703","execution_time":20.622832}
Partition: 0   Offset: 7762   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:19:43.324 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T10:19:43.324560","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:43.324553","end_time":null,"execution_time":null}
Partition: 0   Offset: 7763   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.644 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T10:20:05.644330","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:19:43.324553","end_time":"2025-11-04T10:20:05.644320","execution_time":22.319767}
Partition: 0   Offset: 7764   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.647 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T10:20:05.647665","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:20:05.647660","end_time":null,"execution_time":null}
Partition: 0   Offset: 7765   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.652 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T10:20:05.652320","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:20:05.647660","end_time":"2025-11-04T10:20:05.652298","execution_time":0.004638}
Partition: 0   Offset: 7766   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.653 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T10:20:05.653917","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:20:05.653912","end_time":null,"execution_time":null}
Partition: 0   Offset: 7767   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.655 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T10:20:05.655639","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T10:20:05.653912","end_time":"2025-11-04T10:20:05.655631","execution_time":0.001719}
Partition: 0   Offset: 7768   Key: wf_email_7ced23ec   Timestamp: 2025-11-04 10:20:05.661 Headers: empty
  
{"doc_workflow_id":"wf_email_7ced23ec","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T10:20:05.661023","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"b01757a2-96d2-4ad4-b41c-5554d5472da1","file_name":"cleanco inv-1006.pdf","content_length":0,"execution_time":58.919173,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":58.900926}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7769   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:36.026 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T12:04:36.026263","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/d400cb729107ce018aa5e84322d8bd72c54260c43ad6c5cedbe915be997ab7ae.pdf","document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","email_metadata":{"uploaded_at":"2025-11-04T12:04:35.999662827Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"3.pdf","file_type":"application/pdf; name=\"3.pdf\"","document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9"}],"subject":"process these attachment","grant_id":"05d626c6-81ff-45b3-ba06-8c9fb4e5b2cd","attachment_id":509,"task_id":491,"message_id":"19a4d8f98aec9cb0","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7770   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:36.031 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T12:04:36.031163","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.031157","end_time":null,"execution_time":null}
Partition: 0   Offset: 7771   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:36.199 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T12:04:36.199795","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.031157","end_time":"2025-11-04T12:04:36.199784","execution_time":0.168627}
Partition: 0   Offset: 7772   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:36.202 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T12:04:36.202248","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":62219},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.202243","end_time":null,"execution_time":null}
Partition: 0   Offset: 7773   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:36.531 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T12:04:36.531734","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/d412650240a4fdaac3f2759068ebb3fe9b2bca06407740a6cd8dad4146a42e89.pdf","document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","email_metadata":{"uploaded_at":"2025-11-04T12:04:36.514184548Z","sender":"madhawa@redowl.ai","is_updated":false,"documents":[{"file_name":"1.4.2(ct-inv-50-1025).pdf","file_type":"application/pdf; name=\"1.4.2(CT-INV-50-1025).pdf\"","document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e"},{"file_name":"harbourbridge inv-1003.pdf","file_type":"application/pdf; name=\"Harbourbridge INV-1003.pdf\"","document_id":"5894ca48-bda4-4da2-ae95-75db663b318c"}],"subject":"check this invoice","grant_id":"05d626c6-81ff-45b3-ba06-8c9fb4e5b2cd","attachment_id":511,"task_id":492,"message_id":"19a4d8a272dc6cae","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7774   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:36.535 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T12:04:36.535269","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.535263","end_time":null,"execution_time":null}
Partition: 0   Offset: 7775   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:36.545 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T12:04:36.545165","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/764719560dc3d6f00267313f55d68713a8fb4682dee0813a7e4dd4dc61146943.pdf","document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","email_metadata":{"uploaded_at":"2025-11-04T12:04:36.513904419Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"1.4.2(ct-inv-50-1025).pdf","file_type":"application/pdf; name=\"1.4.2(CT-INV-50-1025).pdf\"","document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e"},{"file_name":"harbourbridge inv-1003.pdf","file_type":"application/pdf; name=\"Harbourbridge INV-1003.pdf\"","document_id":"5894ca48-bda4-4da2-ae95-75db663b318c"}],"subject":"check this invoice","grant_id":"05d626c6-81ff-45b3-ba06-8c9fb4e5b2cd","attachment_id":510,"task_id":492,"message_id":"19a4d8a272dc6cae","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7776   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:36.549 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T12:04:36.549036","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.549030","end_time":null,"execution_time":null}
Partition: 0   Offset: 7777   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:36.583 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T12:04:36.583310","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.535263","end_time":"2025-11-04T12:04:36.583298","execution_time":0.048035}
Partition: 0   Offset: 7778   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:36.585 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T12:04:36.585437","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":65869},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.585432","end_time":null,"execution_time":null}
Partition: 0   Offset: 7779   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:36.718 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T12:04:36.718133","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.549030","end_time":"2025-11-04T12:04:36.718122","execution_time":0.169092}
Partition: 0   Offset: 7780   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:36.720 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T12:04:36.720081","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":302541},"error_message":null,"document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.720075","end_time":null,"execution_time":null}
Partition: 0   Offset: 7781   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:36.739 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-04T12:04:36.739112","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/ce6f4da2a2b863d8e4af119d39ad58671d73403251788921217867f0a2a653c1.pdf","document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","email_metadata":{"uploaded_at":"2025-11-04T12:04:36.717047864Z","sender":"madhawa@redowl.ai","is_updated":false,"documents":[{"file_name":"global stationery inv-1020.pdf","file_type":"application/pdf; name=\"Global Stationery INV-1020.pdf\"","document_id":"fca19a01-d000-4e07-bbc9-127384b1154d"}],"subject":"please give status","grant_id":"05d626c6-81ff-45b3-ba06-8c9fb4e5b2cd","attachment_id":512,"task_id":490,"message_id":"19a4e340fb6cf022","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7782   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:36.794 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-04T12:04:36.794030","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.794024","end_time":null,"execution_time":null}
Partition: 0   Offset: 7783   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:36.819 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-04T12:04:36.819661","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.794024","end_time":"2025-11-04T12:04:36.819650","execution_time":0.025626}
Partition: 0   Offset: 7784   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:36.822 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-04T12:04:36.822014","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":67214},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.822009","end_time":null,"execution_time":null}
Partition: 0   Offset: 7785   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:50.373 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T12:04:50.373787","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":67214},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.822009","end_time":"2025-11-04T12:04:50.373778","execution_time":13.551769}
Partition: 0   Offset: 7786   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:04:50.375 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T12:04:50.375138","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:50.375132","end_time":null,"execution_time":null}
Partition: 0   Offset: 7787   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:51.801 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T12:04:51.801849","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":62219},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.202243","end_time":"2025-11-04T12:04:51.801839","execution_time":15.599596}
Partition: 0   Offset: 7788   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:04:51.803 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T12:04:51.803370","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:51.803365","end_time":null,"execution_time":null}
Partition: 0   Offset: 7789   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:52.433 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T12:04:52.433136","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":65869},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.585432","end_time":"2025-11-04T12:04:52.433126","execution_time":15.847694}
Partition: 0   Offset: 7790   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:04:52.434 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T12:04:52.434759","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:52.434754","end_time":null,"execution_time":null}
Partition: 0   Offset: 7791   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:52.874 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-04T12:04:52.874001","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":302541},"error_message":null,"document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:36.720075","end_time":"2025-11-04T12:04:52.873991","execution_time":16.153916}
Partition: 0   Offset: 7792   Key: wf_email_7dc7381b   Timestamp: 2025-11-04 12:04:52.877 Headers: empty
  
{"doc_workflow_id":"wf_email_7dc7381b","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-04T12:04:52.876927","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"4389cf2b-b1a8-41c3-9495-78c49ed4e66e","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:52.876921","end_time":null,"execution_time":null}
Partition: 0   Offset: 7793   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:13.210 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T12:05:13.210115","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:50.375132","end_time":"2025-11-04T12:05:13.210105","execution_time":22.834973}
Partition: 0   Offset: 7794   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:13.212 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T12:05:13.212443","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:13.212438","end_time":null,"execution_time":null}
Partition: 0   Offset: 7795   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:14.583 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T12:05:14.583695","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:52.434754","end_time":"2025-11-04T12:05:14.583684","execution_time":22.14893}
Partition: 0   Offset: 7796   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:14.585 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T12:05:14.585303","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:14.585298","end_time":null,"execution_time":null}
Partition: 0   Offset: 7797   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:05:34.170 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-04T12:05:34.170088","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:04:51.803365","end_time":"2025-11-04T12:05:34.170077","execution_time":42.366712}
Partition: 0   Offset: 7798   Key: wf_email_55d9ea53   Timestamp: 2025-11-04 12:05:34.172 Headers: empty
  
{"doc_workflow_id":"wf_email_55d9ea53","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-04T12:05:34.172457","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5799f7d6-bd4a-406f-a2d1-df21deb1d3f9","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:34.172452","end_time":null,"execution_time":null}
Partition: 0   Offset: 7799   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.452 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T12:05:34.451925","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:13.212438","end_time":"2025-11-04T12:05:34.451915","execution_time":21.239477}
Partition: 0   Offset: 7800   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.454 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T12:05:34.454564","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:34.454559","end_time":null,"execution_time":null}
Partition: 0   Offset: 7801   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.459 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T12:05:34.459276","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:34.454559","end_time":"2025-11-04T12:05:34.459266","execution_time":0.004707}
Partition: 0   Offset: 7802   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.474 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T12:05:34.474163","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:34.474156","end_time":null,"execution_time":null}
Partition: 0   Offset: 7803   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.476 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T12:05:34.476894","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:34.474156","end_time":"2025-11-04T12:05:34.476884","execution_time":0.002728}
Partition: 0   Offset: 7804   Key: wf_email_754af99b   Timestamp: 2025-11-04 12:05:34.484 Headers: empty
  
{"doc_workflow_id":"wf_email_754af99b","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T12:05:34.484384","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"fca19a01-d000-4e07-bbc9-127384b1154d","file_name":"global stationery inv-1020.pdf","content_length":0,"execution_time":57.691203,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":57.65928}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 7805   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.158 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-04T12:05:42.158675","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:14.585298","end_time":"2025-11-04T12:05:42.158659","execution_time":27.573361}
Partition: 0   Offset: 7806   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.162 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-04T12:05:42.162759","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:42.162745","end_time":null,"execution_time":null}
Partition: 0   Offset: 7807   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.166 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-04T12:05:42.166283","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:42.162745","end_time":"2025-11-04T12:05:42.166269","execution_time":0.003524}
Partition: 0   Offset: 7808   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.184 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-04T12:05:42.184197","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:42.184189","end_time":null,"execution_time":null}
Partition: 0   Offset: 7809   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.185 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-04T12:05:42.185745","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","tenant_id":"dca53ab9-a273-405a-9edc-3ccad0743b73","workflow_status":"started","start_time":"2025-11-04T12:05:42.184189","end_time":"2025-11-04T12:05:42.185733","execution_time":0.001544}
Partition: 0   Offset: 7810   Key: wf_email_d1750a60   Timestamp: 2025-11-04 12:05:42.190 Headers: empty
  
{"doc_workflow_id":"wf_email_d1750a60","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-04T12:05:42.190659","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"5894ca48-bda4-4da2-ae95-75db663b318c","file_name":"harbourbridge inv-1003.pdf","content_length":0,"execution_time":65.656586,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":65.623088}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10884   Key: WF_DOCUMENT_09dd0384   Timestamp: 2025-11-12 03:13:53.984 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_09dd0384","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-12T03:13:53.984430","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"9ddee757-180a-4db9-9b35-7ea9b14bacf7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:13:53.984424","end_time":null,"execution_time":null}
Partition: 0   Offset: 10885   Key: WF_DOCUMENT_09dd0384   Timestamp: 2025-11-12 03:13:53.985 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_09dd0384","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-12T03:13:53.985775","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"9ddee757-180a-4db9-9b35-7ea9b14bacf7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:13:53.984424","end_time":"2025-11-12T03:13:53.985766","execution_time":0.001342}
Partition: 0   Offset: 10886   Key: WF_DOCUMENT_09dd0384   Timestamp: 2025-11-12 03:13:53.990 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_09dd0384","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-12T03:13:53.989973","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"9ddee757-180a-4db9-9b35-7ea9b14bacf7","file_name":"dupli uj 30.pdf","content_length":0,"execution_time":81.333933,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":81.31794000000001}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10887   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:01.272 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-12T03:25:01.272112","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/8cf55355d2e9179ca6641a20df381ffd95f00c3f47396dace61b55f351e9b102.pdf","document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","email_metadata":{"uploaded_at":"2025-11-12T03:25:01.254824752Z","sender":"akila@redowl.ai","is_updated":false,"documents":[{"file_name":"dupli uj 30_3.pdf","file_type":"application/pdf; name=\"Dupli UJ 30_3.pdf\"","document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c"}],"subject":"UJ 30 DPL 3","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":735,"task_id":781,"message_id":"19a7618166dd1d69","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10888   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:01.275 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-12T03:25:01.275563","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:01.275557","end_time":null,"execution_time":null}
Partition: 0   Offset: 10889   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:01.341 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-12T03:25:01.341018","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:01.275557","end_time":"2025-11-12T03:25:01.341007","execution_time":0.06545}
Partition: 0   Offset: 10890   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:01.343 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-12T03:25:01.343065","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61084},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:01.343059","end_time":null,"execution_time":null}
Partition: 0   Offset: 10891   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:24.386 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-12T03:25:24.386585","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":61084},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:01.343059","end_time":"2025-11-12T03:25:24.386576","execution_time":23.043517}
Partition: 0   Offset: 10892   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:24.388 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-12T03:25:24.388317","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:24.388313","end_time":null,"execution_time":null}
Partition: 0   Offset: 10893   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:53.445 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-12T03:25:53.445120","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:24.388313","end_time":"2025-11-12T03:25:53.445109","execution_time":29.056796}
Partition: 0   Offset: 10894   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:25:53.447 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-12T03:25:53.447117","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:53.447112","end_time":null,"execution_time":null}
Partition: 0   Offset: 10895   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.758 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-12T03:26:23.758836","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:25:53.447112","end_time":"2025-11-12T03:26:23.758826","execution_time":30.311714}
Partition: 0   Offset: 10896   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.760 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-12T03:26:23.760436","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:26:23.760432","end_time":null,"execution_time":null}
Partition: 0   Offset: 10897   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.764 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-12T03:26:23.764795","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:26:23.760432","end_time":"2025-11-12T03:26:23.764784","execution_time":0.004352}
Partition: 0   Offset: 10898   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.783 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-12T03:26:23.783593","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:26:23.783586","end_time":null,"execution_time":null}
Partition: 0   Offset: 10899   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.785 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-12T03:26:23.785314","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-12T03:26:23.783586","end_time":"2025-11-12T03:26:23.785306","execution_time":0.00172}
Partition: 0   Offset: 10900   Key: WF_DOCUMENT_6d7603e7   Timestamp: 2025-11-12 03:26:23.788 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_6d7603e7","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-12T03:26:23.788181","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"23210e8d-2ddf-496d-b6d7-5290a63e135c","file_name":"dupli uj 30_3.pdf","content_length":0,"execution_time":82.513986,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":82.483549}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10901   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:23.151 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:11:23.151195","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/1d53e5d9371e1ec4d6b537be7088dfbe6cc186cab4e893eed47ea85b6c94e03e.pdf","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","email_metadata":{"uploaded_at":"2025-11-13T08:11:23.134081925Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"ad321f97-b76d-4460-8282-4cd220e936ef"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"}],"subject":"please check this invocies","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":738,"task_id":785,"message_id":"19a7c4471eb45c12","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10902   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:23.155 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:11:23.155284","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.155278","end_time":null,"execution_time":null}
Partition: 0   Offset: 10903   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:23.170 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:11:23.170356","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/bb4d4959e4338142c1042a22706f1d624fefbda244b4d5765608544edf19b3fd.pdf","document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","email_metadata":{"uploaded_at":"2025-11-13T08:11:23.134915745Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"ad321f97-b76d-4460-8282-4cd220e936ef"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"}],"subject":"please check this invocies","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":737,"task_id":785,"message_id":"19a7c4471eb45c12","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10904   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:23.175 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:11:23.175697","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.175690","end_time":null,"execution_time":null}
Partition: 0   Offset: 10905   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:23.176 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:11:23.176209","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/7b24ecc8472696f1c4ec9f61531d21018455c61787011434d5d4e89847d1b99a.pdf","document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","email_metadata":{"uploaded_at":"2025-11-13T08:11:23.138594871Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"ad321f97-b76d-4460-8282-4cd220e936ef"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"}],"subject":"please check this invocies","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":739,"task_id":785,"message_id":"19a7c4471eb45c12","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10906   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:23.179 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:11:23.179158","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.179152","end_time":null,"execution_time":null}
Partition: 0   Offset: 10907   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:23.272 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:11:23.272606","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.179152","end_time":"2025-11-13T08:11:23.272593","execution_time":0.093441}
Partition: 0   Offset: 10908   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:23.274 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:11:23.274452","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2591},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.274447","end_time":null,"execution_time":null}
Partition: 0   Offset: 10909   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:23.281 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:11:23.281741","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.155278","end_time":"2025-11-13T08:11:23.281731","execution_time":0.126453}
Partition: 0   Offset: 10910   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:23.283 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:11:23.283722","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.175690","end_time":"2025-11-13T08:11:23.283711","execution_time":0.108021}
Partition: 0   Offset: 10911   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:23.284 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:11:23.284725","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2684},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.284720","end_time":null,"execution_time":null}
Partition: 0   Offset: 10912   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:23.294 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:11:23.294604","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":48110},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.294598","end_time":null,"execution_time":null}
Partition: 0   Offset: 10913   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:46.996 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:11:46.996371","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2684},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.284720","end_time":"2025-11-13T08:11:46.996361","execution_time":23.711641}
Partition: 0   Offset: 10914   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:11:46.998 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:11:46.998230","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:46.998225","end_time":null,"execution_time":null}
Partition: 0   Offset: 10915   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:47.666 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:11:47.666418","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2591},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.274447","end_time":"2025-11-13T08:11:47.666408","execution_time":24.391961}
Partition: 0   Offset: 10916   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:11:47.668 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:11:47.668179","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:47.668175","end_time":null,"execution_time":null}
Partition: 0   Offset: 10917   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:50.197 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:11:50.197041","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":48110},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:23.294598","end_time":"2025-11-13T08:11:50.197032","execution_time":26.902434}
Partition: 0   Offset: 10918   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:11:50.199 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:11:50.199836","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:50.199831","end_time":null,"execution_time":null}
Partition: 0   Offset: 10919   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:18.977 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:18.976984","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:47.668175","end_time":"2025-11-13T08:12:18.976975","execution_time":31.3088}
Partition: 0   Offset: 10920   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:18.979 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:12:18.979570","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:18.979564","end_time":null,"execution_time":null}
Partition: 0   Offset: 10921   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:19.856 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:19.855987","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:50.199831","end_time":"2025-11-13T08:12:19.855976","execution_time":29.656145}
Partition: 0   Offset: 10922   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:19.858 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:12:19.857999","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:19.857995","end_time":null,"execution_time":null}
Partition: 0   Offset: 10923   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:19.917 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:19.917274","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:11:46.998225","end_time":"2025-11-13T08:12:19.917263","execution_time":32.919038}
Partition: 0   Offset: 10924   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:19.919 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:12:19.919902","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:19.919897","end_time":null,"execution_time":null}
Partition: 0   Offset: 10925   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.503 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:43.503347","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:18.979564","end_time":"2025-11-13T08:12:43.503336","execution_time":24.523772}
Partition: 0   Offset: 10926   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.505 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:12:43.505245","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:43.505240","end_time":null,"execution_time":null}
Partition: 0   Offset: 10927   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.508 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:12:43.508258","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:43.505240","end_time":"2025-11-13T08:12:43.508249","execution_time":0.003009}
Partition: 0   Offset: 10928   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.523 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:12:43.523684","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:43.523677","end_time":null,"execution_time":null}
Partition: 0   Offset: 10929   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.525 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:12:43.525367","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:43.523677","end_time":"2025-11-13T08:12:43.525357","execution_time":0.00168}
Partition: 0   Offset: 10930   Key: WF_DOCUMENT_b35dd21e   Timestamp: 2025-11-13 08:12:43.528 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b35dd21e","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:12:43.528900","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","file_name":"uj 11_credit_note.pdf","content_length":0,"execution_time":80.351065,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":80.32266299999999}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10931   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.315 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:45.315322","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:19.919897","end_time":"2025-11-13T08:12:45.315311","execution_time":25.395414}
Partition: 0   Offset: 10932   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.318 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:12:45.318495","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:45.318489","end_time":null,"execution_time":null}
Partition: 0   Offset: 10933   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.323 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:12:45.322918","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:45.318489","end_time":"2025-11-13T08:12:45.322906","execution_time":0.004417}
Partition: 0   Offset: 10934   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.324 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:12:45.324472","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:45.324465","end_time":null,"execution_time":null}
Partition: 0   Offset: 10935   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.329 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:12:45.329312","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:45.324465","end_time":"2025-11-13T08:12:45.329301","execution_time":0.004836}
Partition: 0   Offset: 10936   Key: WF_DOCUMENT_103e93cb   Timestamp: 2025-11-13 08:12:45.334 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_103e93cb","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:12:45.334197","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","file_name":"uj 11_grn.pdf","content_length":0,"execution_time":82.180261,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":82.161799}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10937   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.249 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:12:46.249337","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:19.857995","end_time":"2025-11-13T08:12:46.249326","execution_time":26.391331}
Partition: 0   Offset: 10938   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.251 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:12:46.250945","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:46.250940","end_time":null,"execution_time":null}
Partition: 0   Offset: 10939   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.254 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:12:46.253989","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:46.250940","end_time":"2025-11-13T08:12:46.253981","execution_time":0.003041}
Partition: 0   Offset: 10940   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.257 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:12:46.257467","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:46.257461","end_time":null,"execution_time":null}
Partition: 0   Offset: 10941   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.258 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:12:46.258604","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:12:46.257461","end_time":"2025-11-13T08:12:46.258594","execution_time":0.001133}
Partition: 0   Offset: 10942   Key: WF_DOCUMENT_77b224fc   Timestamp: 2025-11-13 08:12:46.261 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_77b224fc","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:12:46.260968","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","file_name":"uj 11_invoice.pdf","content_length":0,"execution_time":83.086667,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":83.06210499999999}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10943   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:15:47.077 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:15:47.076942","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/bb4d4959e4338142c1042a22706f1d624fefbda244b4d5765608544edf19b3fd.pdf","document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","email_metadata":{"uploaded_at":"2025-11-13T08:15:47.061759750Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"9229b012-7153-490b-b021-9c5a9c277abc"}],"subject":"please check these attachments","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":744,"task_id":786,"message_id":"19a7c483d9c3e44a","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10944   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:15:47.080 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:15:47.080485","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.080480","end_time":null,"execution_time":null}
Partition: 0   Offset: 10945   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:15:47.094 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:15:47.094146","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/7b24ecc8472696f1c4ec9f61531d21018455c61787011434d5d4e89847d1b99a.pdf","document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","email_metadata":{"uploaded_at":"2025-11-13T08:15:47.063869969Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"9229b012-7153-490b-b021-9c5a9c277abc"}],"subject":"please check these attachments","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":741,"task_id":786,"message_id":"19a7c483d9c3e44a","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10946   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:15:47.099 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:15:47.099010","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.098993","end_time":null,"execution_time":null}
Partition: 0   Offset: 10947   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:15:47.102 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"WORKFLOW_STARTED","timestamp":"2025-11-13T08:15:47.102762","node_id":null,"node_name":null,"status":"started","data":{"tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_type":"email","file_path":"s3://redowl-drive-dev/AP_FRONTDESK/APF/agent-12/2025-11/1d53e5d9371e1ec4d6b537be7088dfbe6cc186cab4e893eed47ea85b6c94e03e.pdf","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","email_metadata":{"uploaded_at":"2025-11-13T08:15:47.061606394Z","sender":"madhawa@redowl.ai","is_updated":true,"documents":[{"file_name":"uj 11_credit_note.pdf","file_type":"application/pdf; name=\"UJ 11_Credit_Note.pdf\"","document_id":"049a2c09-ba9b-4122-bb64-9c928c546840"},{"file_name":"uj 11_grn.pdf","file_type":"application/pdf; name=\"UJ 11_GRN.pdf\"","document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7"},{"file_name":"uj 11_invoice.pdf","file_type":"application/pdf; name=\"UJ 11_Invoice.pdf\"","document_id":"9229b012-7153-490b-b021-9c5a9c277abc"}],"subject":"please check these attachments","grant_id":"57f7a91a-7014-4148-95a1-31cd7fd0d411","attachment_id":740,"task_id":786,"message_id":"19a7c483d9c3e44a","source":"email-automation-service","document_type":""}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10948   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:15:47.105 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"document_retrieve_NODE_STARTED","timestamp":"2025-11-13T08:15:47.105568","node_id":null,"node_name":"document_retrieve","status":"started","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.105563","end_time":null,"execution_time":null}
Partition: 0   Offset: 10949   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:15:47.177 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:15:47.177092","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.105563","end_time":"2025-11-13T08:15:47.177080","execution_time":0.071517}
Partition: 0   Offset: 10950   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:15:47.179 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:15:47.179624","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2684},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.179619","end_time":null,"execution_time":null}
Partition: 0   Offset: 10951   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:15:47.184 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:15:47.184896","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.098993","end_time":"2025-11-13T08:15:47.184886","execution_time":0.085893}
Partition: 0   Offset: 10952   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:15:47.188 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"document_retrieve_NODE_COMPLETED","timestamp":"2025-11-13T08:15:47.188738","node_id":null,"node_name":"document_retrieve","status":"completed","data":{"input_event_type":"EmailProcessingStartEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.080480","end_time":"2025-11-13T08:15:47.188727","execution_time":0.108247}
Partition: 0   Offset: 10953   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:15:47.190 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:15:47.190264","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2591},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.190259","end_time":null,"execution_time":null}
Partition: 0   Offset: 10954   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:15:47.201 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"document classification_NODE_STARTED","timestamp":"2025-11-13T08:15:47.201475","node_id":null,"node_name":"document classification","status":"started","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":48110},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.201469","end_time":null,"execution_time":null}
Partition: 0   Offset: 10955   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:16:12.566 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:16:12.565959","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2684},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.179619","end_time":"2025-11-13T08:16:12.565949","execution_time":25.38633}
Partition: 0   Offset: 10956   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:16:12.568 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:16:12.568288","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:12.568284","end_time":null,"execution_time":null}
Partition: 0   Offset: 10957   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:16:13.923 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:16:13.923915","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":48110},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.201469","end_time":"2025-11-13T08:16:13.923905","execution_time":26.722436}
Partition: 0   Offset: 10958   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:16:13.926 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:16:13.926108","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:13.926103","end_time":null,"execution_time":null}
Partition: 0   Offset: 10959   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:16:14.287 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"document classification_NODE_COMPLETED","timestamp":"2025-11-13T08:16:14.287157","node_id":null,"node_name":"document classification","status":"completed","data":{"input_event_type":"DocumentRetrievedEvent","document_byte_length":2591},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:15:47.190259","end_time":"2025-11-13T08:16:14.287147","execution_time":27.096888}
Partition: 0   Offset: 10960   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:16:14.289 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"data_extraction_NODE_STARTED","timestamp":"2025-11-13T08:16:14.289420","node_id":null,"node_name":"data_extraction","status":"started","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:14.289416","end_time":null,"execution_time":null}
Partition: 0   Offset: 10961   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:16:37.500 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:16:37.499937","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:12.568284","end_time":"2025-11-13T08:16:37.499928","execution_time":24.931644}
Partition: 0   Offset: 10962   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:16:37.501 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:16:37.501933","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:37.501929","end_time":null,"execution_time":null}
Partition: 0   Offset: 10963   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:16:43.127 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:16:43.127055","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:13.926103","end_time":"2025-11-13T08:16:43.127045","execution_time":29.200942}
Partition: 0   Offset: 10964   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:16:43.128 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:16:43.128815","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:43.128810","end_time":null,"execution_time":null}
Partition: 0   Offset: 10965   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:16:45.034 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"data_extraction_NODE_COMPLETED","timestamp":"2025-11-13T08:16:45.034569","node_id":null,"node_name":"data_extraction","status":"completed","data":{"input_event_type":"ClassificationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:14.289416","end_time":"2025-11-13T08:16:45.034555","execution_time":30.745139}
Partition: 0   Offset: 10966   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:16:45.037 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"validation_and_correction_NODE_STARTED","timestamp":"2025-11-13T08:16:45.037373","node_id":null,"node_name":"validation_and_correction","status":"started","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:45.037367","end_time":null,"execution_time":null}
Partition: 0   Offset: 10967   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.912 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:17:00.912474","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:37.501929","end_time":"2025-11-13T08:17:00.912461","execution_time":23.410532}
Partition: 0   Offset: 10968   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.917 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:17:00.917891","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:00.917884","end_time":null,"execution_time":null}
Partition: 0   Offset: 10969   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.926 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:17:00.926430","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:00.917884","end_time":"2025-11-13T08:17:00.926392","execution_time":0.008508}
Partition: 0   Offset: 10970   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.932 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:17:00.931307","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:00.931296","end_time":null,"execution_time":null}
Partition: 0   Offset: 10971   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.939 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:17:00.939412","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:00.931296","end_time":"2025-11-13T08:17:00.939397","execution_time":0.008101}
Partition: 0   Offset: 10972   Key: WF_DOCUMENT_12ce04a8   Timestamp: 2025-11-13 08:17:00.945 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_12ce04a8","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:17:00.945224","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"049a2c09-ba9b-4122-bb64-9c928c546840","file_name":"uj 11_grn.pdf","content_length":0,"execution_time":73.840569,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":73.816632}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10973   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.501 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:17:11.501131","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:45.037367","end_time":"2025-11-13T08:17:11.501121","execution_time":26.463754}
Partition: 0   Offset: 10974   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.502 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:17:11.502738","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:11.502733","end_time":null,"execution_time":null}
Partition: 0   Offset: 10975   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.507 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:17:11.507696","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:11.502733","end_time":"2025-11-13T08:17:11.507685","execution_time":0.004952}
Partition: 0   Offset: 10976   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.515 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:17:11.515492","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:11.515486","end_time":null,"execution_time":null}
Partition: 0   Offset: 10977   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.516 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:17:11.516776","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:11.515486","end_time":"2025-11-13T08:17:11.516767","execution_time":0.001281}
Partition: 0   Offset: 10978   Key: WF_DOCUMENT_3bdee61e   Timestamp: 2025-11-13 08:17:11.520 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_3bdee61e","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:17:11.520420","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"d9eda758-92b9-409b-b46a-51bd15969bc7","file_name":"uj 11_credit_note.pdf","content_length":0,"execution_time":84.422852,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":84.397907}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}
Partition: 0   Offset: 10979   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.251 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"validation_and_correction_NODE_COMPLETED","timestamp":"2025-11-13T08:17:17.251646","node_id":null,"node_name":"validation_and_correction","status":"completed","data":{"input_event_type":"DataEnrichmentCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:16:43.128810","end_time":"2025-11-13T08:17:17.251636","execution_time":34.122826}
Partition: 0   Offset: 10980   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.253 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"event_publishing_NODE_STARTED","timestamp":"2025-11-13T08:17:17.253881","node_id":null,"node_name":"event_publishing","status":"started","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:17.253875","end_time":null,"execution_time":null}
Partition: 0   Offset: 10981   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.260 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"event_publishing_NODE_COMPLETED","timestamp":"2025-11-13T08:17:17.260424","node_id":null,"node_name":"event_publishing","status":"completed","data":{"input_event_type":"ValidationCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:17.253875","end_time":"2025-11-13T08:17:17.260414","execution_time":0.006539}
Partition: 0   Offset: 10982   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.261 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"vector_storage_NODE_STARTED","timestamp":"2025-11-13T08:17:17.261671","node_id":null,"node_name":"vector_storage","status":"started","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:17.261665","end_time":null,"execution_time":null}
Partition: 0   Offset: 10983   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.265 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"vector_storage_NODE_COMPLETED","timestamp":"2025-11-13T08:17:17.265182","node_id":null,"node_name":"vector_storage","status":"completed","data":{"input_event_type":"EventPublishingCompletedEvent","document_byte_length":null},"error_message":null,"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","tenant_id":"5328a721-c716-4399-8d74-5c3f98b224da","workflow_status":"started","start_time":"2025-11-13T08:17:17.261665","end_time":"2025-11-13T08:17:17.265171","execution_time":0.003506}
Partition: 0   Offset: 10984   Key: WF_DOCUMENT_b8b49de2   Timestamp: 2025-11-13 08:17:17.271 Headers: empty
  
{"doc_workflow_id":"WF_DOCUMENT_b8b49de2","event_type":"WORKFLOW_COMPLETED","timestamp":"2025-11-13T08:17:17.271767","node_id":null,"node_name":null,"status":"completed","data":{"document_id":"b60f64b0-f7c6-44c1-8948-b2d37421cec5","file_name":"uj 11_invoice.pdf","content_length":0,"execution_time":90.192506,"final_status":"success","nodes_summary":{"total_nodes":6,"completed":6,"failed":0,"in_progress":0,"total_nodes_execution_time":90.164496}},"error_message":null,"document_id":null,"tenant_id":null,"workflow_status":null,"start_time":null,"end_time":null,"execution_time":null}