owen
12/29/2022, 3:10 PM@op(ins={"cc_id": In(), "tbl": In(), "start_after": In(Nothing))
def cf_run_event_processing(context, cc_id, tbl):
then your job would have
meltano_done = meltano_run_op(...)()
cc_id, cache_key = cf_run_event_processing(..., start_after=meltano_done)
Oleksandr (Alex) Dimov
01/09/2023, 5:14 PM