Update 'feature_envelope_pfi_scheduler.py'

feature_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 = '/calculate-feature'
+    endpoint = '/envelope/calculate-feature'
     
     # Generate request ID untuk tracking
     request_id = str(uuid.uuid4())
@@ -101,8 +101,8 @@ feature_envelope_async = PythonOperator(
 # Ini hanya untuk memulai request tanpa menunggu respons lengkap
 feature_envelope_alt = HttpOperator(
     task_id='feature_envelope_alt',
-    http_conn_id='envelope-pfi-app',
-    endpoint='/calculate-feature',
+    http_conn_id='pfi-api',
+    endpoint='/envelope/calculate-feature',
     method='GET',
     headers={
         'Content-Type': 'application/json',