diff --git a/dags/wmes/lpms_process_shef_lrd.py b/dags/wmes/lpms_process_shef_lrd.py index 1d60145..3b9f04d 100644 --- a/dags/wmes/lpms_process_shef_lrd.py +++ b/dags/wmes/lpms_process_shef_lrd.py @@ -47,11 +47,11 @@ def fetch_lpms_data(): lookback_hours = 4 # LPMS SHEF LRD endpoint: https://ndc-navapps.ops.usace.army.mil/ords/lpms2/shef/LRD/yyyymmddhhmm/lookbackhours - lpms_url = lpms_url = "http://nav-app1-prod1.cwbi.lan:8080/ords/lpms2/shef/LRD" + lpms_url = "http://nav-app1-prod1.cwbi.lan:8080/ords/lpms2/shef/LRD" if S3_BUCKET == "wmes-airflow-test": - lpms_url = "http://nav-app3-test.cwbi.lan:8080/ords/lpms2/shef/LRD/" + lpms_url = "http://nav-app3-test.cwbi.lan:8080/ords/lpms2/shef/LRD" elif S3_BUCKET == "wmes-airflow-dev": - lpms_url = "https://ndc-navapps.ops.usace.army.mil/ords/lpms2/shef/LRD/" + lpms_url = "https://ndc-navapps.ops.usace.army.mil/ords/lpms2/shef/LRD" request_url = f"{lpms_url}/{now_et}/{lookback_hours}" logging.info(f"grabbing file from: {request_url}") response = requests.get(request_url)