Improve example DAGs for Cloud Memorystore (#7855)

apache · Mar 26, 2020 · 8ba8a72 · 8ba8a72
1 parent f7d1a43
commit 8ba8a72
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/airflow/providers/google/cloud/example_dags/example_cloud_memorystore.py b/airflow/providers/google/cloud/example_dags/example_cloud_memorystore.py
@@ -88,7 +88,11 @@
 
     # [START howto_operator_get_instance]
     get_instance = CloudMemorystoreGetInstanceOperator(
-        task_id="get-instance", location="europe-north1", instance=INSTANCE_NAME, project_id=GCP_PROJECT_ID
+        task_id="get-instance",
+        location="europe-north1",
+        instance=INSTANCE_NAME,
+        project_id=GCP_PROJECT_ID,
+        do_xcom_push=True,
     )
     # [END howto_operator_get_instance]
 
@@ -212,6 +216,7 @@
     create_instance_2 >> import_instance
     create_instance >> list_instances >> list_instances_result
     list_instances >> delete_instance
+    export_instance >> update_instance
     update_instance >> delete_instance
     get_instance >> set_acl_permission >> export_instance
     export_instance >> import_instance