walrus 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 := 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())
Comments