Divya
07/22/2022, 5:33 PMKevin Kho
07/22/2022, 5:38 PMDivya
07/22/2022, 7:10 PM@task()
def postgres_task():
loading_job = run_postgres_job()
loading_job.launch()
@task()
def es_launch():
job_es_table = create_es_publisher_sample_job(
elasticsearch_index_alias='table_search_index',
elasticsearch_doc_type_key='table',
model_name='databuilder.models.table_elasticsearch_document.TableESDocument')
job_es_table.launch()
def perfect_flow():
with Flow(name = 'sample_postgres_loader') as flow:
postgres_task()
es_launch()
return flow
if __name__ == "__main__":
flow = perfect_flow()
flow.run()
flow.register(project_name="default")
``````Anna Geller
07/23/2022, 1:37 PM