Update 'fetch_envelope_pfi_scheduler.py'

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',