-
Notifications
You must be signed in to change notification settings - Fork 16.4k
Closed
Labels
AIP-31Task Flow API for nicer DAG definitionTask Flow API for nicer DAG definitioncontributors-workshopIssues that are good for first-time contributor's workshopIssues that are good for first-time contributor's workshopgood first issuekind:featureFeature RequestsFeature Requests
Milestone
Description
Hello,
When we stop releasing backport packages, we will be able to update all example DAGs to use the new syntax for handling outputs introduced by AIP-31.
This is an example change.
product_set_update = CloudVisionUpdateProductSetOperator(
location=GCP_VISION_LOCATION,
- product_set_id="{{ task_instance.xcom_pull('product_set_create') }}",
+ product_set_id=product_set_create.output,
product_set=ProductSet(display_name='My Product Set 2'),
task_id='product_set_update',
)Best regards,
Kamil Bregułła
potiuk, ad-m and ricardogaspar2
Metadata
Metadata
Labels
AIP-31Task Flow API for nicer DAG definitionTask Flow API for nicer DAG definitioncontributors-workshopIssues that are good for first-time contributor's workshopIssues that are good for first-time contributor's workshopgood first issuekind:featureFeature RequestsFeature Requests