(actual prod code for airflow)
[
(
a_data := get_users.partial(
connection_meta=connection_meta
).expand(code=code_a)
),
(
b_data := get_users.partial(
connection_meta=connection_meta
).expand(code=code_b)
),
] >> (fetch_content := content_fetch(a_data, b_data))
Comments