diff --git a/example/dags/postgres_sample_dag.py b/example/dags/postgres_sample_dag.py
index bfaaba476..5ba790c5c 100644
--- 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