From b779bc7ffdbc0adc6ba59d391f854d53a8a39209 Mon Sep 17 00:00:00 2001 From: perdanamain Date: Tue, 18 Mar 2025 07:33:20 +0000 Subject: [PATCH] Update 'fetch_envelope_pfi_scheduler.py' --- fetch_envelope_pfi_scheduler.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/fetch_envelope_pfi_scheduler.py b/fetch_envelope_pfi_scheduler.py index ca14bfd..3ec6405 100644 --- a/fetch_envelope_pfi_scheduler.py +++ b/fetch_envelope_pfi_scheduler.py @@ -41,11 +41,11 @@ def fire_and_forget_api_call(**context): Fungsi ini mengirim permintaan API dan tidak menunggu respons (fire and forget) """ # Menggunakan HttpHook untuk mendapatkan konfigurasi koneksi - http = HttpHook(method='GET', http_conn_id='envelope-pfi-app') + http = HttpHook(method='GET', http_conn_id='pfi-api') # Mendapatkan session dan base URL session = http.get_conn() - endpoint = '/fetch-envelope' + endpoint = '/envelope/fetch-envelope' # Generate request ID untuk tracking request_id = str(uuid.uuid4()) @@ -101,8 +101,8 @@ fetch_envelope_async = PythonOperator( # Ini hanya untuk memulai request tanpa menunggu respons lengkap fetch_envelope_alt = HttpOperator( task_id='fetch_envelope_alt', - http_conn_id='envelope-pfi-app', - endpoint='/fetch-envelope', + http_conn_id='pfi-api', + endpoint='/envelope/fetch-envelope', method='GET', headers={ 'Content-Type': 'application/json',