niclas_roos
02/05/2023, 10:14 AMrow = {
'invoice_id': 1234,
'customer_id': 5678,
'invoice_lines': [
{'invoice_line_id': 1, 'value': 100},
{'invoice_line_id': 2, 'value': 300}]}
And I want the parent stream to output the following to the target:
invoice_stream_row = {
'invoice_id': 1234,
'customer_id': 5678}
Next, I want to send row['invoice_id'] and row['invoice_lines'] to get_child_context() and pick them up from context as if they were a list of records to be handle by the stream, like any response would've been handled, and the yield the following rows as output of the child stream:
invoice_line_stream_rows = [
{'invoice_id': 1234, 'invoice_line_id': 1, 'value': 100},
{'invoice_id': 1234, 'invoice_line_id': 2, 'value': 300}]
Any thoughts?