fix: Update postgres_sample_dag to set table extract job as upstream for elastic search publisher
@@ -170,3 +170,6 @@ with DAG('amundsen_databuilder', default_args=default_args, **dag_args) as dag:
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
