giambattista.bloisi
/
lot1-kickoff
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

simple test DAG

This commit is contained in:
Giambattista Bloisi 2024-03-07 11:01:55 +01:00
parent 7d2da06118
commit d4f33496aa
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
airflow/dags/populate_opensearch.py
View File

@ -80,9 +80,7 @@ def bulk_load():
data=json.dumps(data),
headers={"Content-Type": "application/json"},
verify=False)
session.put("https://opensearch-cluster.lot1-opensearch-cluster.svc.cluster.local:9200/organization_index/_refresh",
data="",
headers={"Content-Type": "application/json"},
session.post("https://opensearch-cluster.lot1-opensearch-cluster.svc.cluster.local:9200/organization_index/_refresh",
verify=False)
with DAG(