From 53a30301466a15765299e783b0a9d1452bc96ee4 Mon Sep 17 00:00:00 2001 From: akumadoferudi Date: Wed, 26 Mar 2025 08:21:24 +0000 Subject: [PATCH] update conn id into prod --- risk_matrix_scheduler_per_hour.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/risk_matrix_scheduler_per_hour.py b/risk_matrix_scheduler_per_hour.py index 6aa12c2..a3118a2 100644 --- a/risk_matrix_scheduler_per_hour.py +++ b/risk_matrix_scheduler_per_hour.py @@ -61,7 +61,7 @@ api5_headers = { # API 1 task fetch_api1 = HttpOperator( task_id='fetch_api1', - http_conn_id='backend-server', # Set up this connection in Airflow + http_conn_id='risk_matrix_app', # Set up this connection in Airflow endpoint=api1_endpoint, method='PATCH', headers=api1_headers, @@ -72,7 +72,7 @@ fetch_api1 = HttpOperator( # API 2 task fetch_api2 = HttpOperator( task_id='fetch_api2', - http_conn_id='backend-server', + http_conn_id='risk_matrix_app', endpoint=api2_endpoint, method='PATCH', headers=api2_headers, @@ -83,7 +83,7 @@ fetch_api2 = HttpOperator( # API 3 task fetch_api3 = HttpOperator( task_id='fetch_api3', - http_conn_id='backend-server', + http_conn_id='risk_matrix_app', endpoint=api3_endpoint, method='PATCH', headers=api3_headers, @@ -94,7 +94,7 @@ fetch_api3 = HttpOperator( # API 4 task fetch_api4 = HttpOperator( task_id='fetch_api4', - http_conn_id='backend-server', + http_conn_id='risk_matrix_app', endpoint=api4_endpoint, method='PATCH', headers=api4_headers, @@ -105,7 +105,7 @@ fetch_api4 = HttpOperator( # API 5 task fetch_api5 = HttpOperator( task_id='fetch_api5', - http_conn_id='backend-server', + http_conn_id='risk_matrix_app', endpoint=api5_endpoint, method='PATCH', headers=api5_headers,