Skip to content

Update example DAG files to latest syntax #10285

@mik-laj

Description

@mik-laj

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

Metadata

Metadata

Labels

AIP-31Task Flow API for nicer DAG definitioncontributors-workshopIssues that are good for first-time contributor's workshopgood first issuekind:featureFeature Requests

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions