I have 2 events coming from Kafka queue with same json schema. Both events will have a field “batch_id” which will be same. I have a workflow with 5 activities say “mainWorkflow”. I want to execute this mainWorkflow twice, one for each event and only then mark the overall operation complete. How to implement this scenario where I want to run a sub-workflow of same type from my mainWorkflow and wait for completion of both these workflows? Should I use a parent/child relationship here or is there a better way to implement this?
I would just run a loop with two iterations within a single workflow.