Skip to content

Commit 8ba8a72

Browse files
authored
Improve example DAGs for Cloud Memorystore (#7855)
1 parent f7d1a43 commit 8ba8a72

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

airflow/providers/google/cloud/example_dags/example_cloud_memorystore.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,11 @@
8888

8989
# [START howto_operator_get_instance]
9090
get_instance = CloudMemorystoreGetInstanceOperator(
91-
task_id="get-instance", location="europe-north1", instance=INSTANCE_NAME, project_id=GCP_PROJECT_ID
91+
task_id="get-instance",
92+
location="europe-north1",
93+
instance=INSTANCE_NAME,
94+
project_id=GCP_PROJECT_ID,
95+
do_xcom_push=True,
9296
)
9397
# [END howto_operator_get_instance]
9498

@@ -212,6 +216,7 @@
212216
create_instance_2 >> import_instance
213217
create_instance >> list_instances >> list_instances_result
214218
list_instances >> delete_instance
219+
export_instance >> update_instance
215220
update_instance >> delete_instance
216221
get_instance >> set_acl_permission >> export_instance
217222
export_instance >> import_instance

0 commit comments

Comments
 (0)