gary_james
02/16/2022, 6:43 PMandrew_stewart
02/16/2022, 7:37 PMandrew_stewart
02/16/2022, 7:37 PMandrew_stewart
02/16/2022, 7:55 PMclass ParentStream(...):
...
def get_child_context(self, record: dict, context: Optional[dict]) -> dict:
"""Return a context dictionary for child streams."""
return record
class ChildStream(ParentStream):
parent_stream_type = ParentStream
...
# Then you can do something like....
def post_process(self, row: dict, context: Optional[dict] = None) -> dict:
for field in context.keys():
row[key] = context[field]
return row
andrew_stewart
02/16/2022, 7:55 PMgary_james
02/16/2022, 7:57 PMandrew_stewart
02/16/2022, 8:02 PMgary_james
02/16/2022, 8:03 PMgary_james
02/16/2022, 8:17 PMandrew_stewart
02/16/2022, 11:10 PM