fix: Update postgres_sample_dag to set table extract job as upstream …

…for elastic search publisher (#340) Signed-off-by: Alagappan Sethuraman <alagappan.als@gmail.com>
amundsen-io · Aug 19, 2020 · c79935e · c79935e
1 parent 804b20c
commit c79935e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/example/dags/postgres_sample_dag.py b/example/dags/postgres_sample_dag.py
@@ -170,3 +170,6 @@ def create_es_publisher_sample_job():
         task_id='create_es_publisher_sample_job',
         python_callable=create_es_publisher_sample_job
     )
+
+    # elastic search update run after table metadata has been updated
+    create_table_extract_job >> create_es_index_job