Add stac browser for prip

Author: Alex Grosu

services/frontend/.github/entrypoint_frontend.sh

@@ -23,12 +23,14 @@ sb_urls=(${STAC_BROWSER_URLS//;/ })
 STAC_BROWSER_URL_ADGS=${sb_urls[0]}
 STAC_BROWSER_URL_CADIP=${sb_urls[1]}
 STAC_BROWSER_URL_CATALOG=${sb_urls[2]}
+STAC_BROWSER_URL_PRIP=${sb_urls[3]}
 
 # Replace environment variables in the openapi.json file
 sed -i "s|\${RSPY_UAC_HOMEPAGE}|${RSPY_UAC_HOMEPAGE:-}|g" $RSPY_OPENAPI_FILE
 sed -i "s|\${STAC_BROWSER_URL_ADGS}|${STAC_BROWSER_URL_ADGS:-}|g" $RSPY_OPENAPI_FILE
 sed -i "s|\${STAC_BROWSER_URL_CADIP}|${STAC_BROWSER_URL_CADIP:-}|g" $RSPY_OPENAPI_FILE
 sed -i "s|\${STAC_BROWSER_URL_CATALOG}|${STAC_BROWSER_URL_CATALOG:-}|g" $RSPY_OPENAPI_FILE
+sed -i "s|\${STAC_BROWSER_URL_PRIP}|${STAC_BROWSER_URL_PRIP:-}|g" $RSPY_OPENAPI_FILE
 
 # Run the FastAPI application
 python -m uvicorn --factory rs_server_frontend.main:start_app --host 0.0.0.0 --port 8000 "$@"

services/frontend/resources/build_aggregated_openapi.sh

@@ -118,6 +118,7 @@ if [[ " $@ " == *" --run-services "* ]]; then
     # Use postgres database
     run_local_service "../adgs" "rs_server_adgs.fastapi.adgs_app:app" 8001 "health"
     run_local_service "../cadip" "rs_server_cadip.fastapi.cadip_app:app" 8002 "health"
+    run_local_service "../prip" "rs_server_prip.fastapi.prip_app:app" 8005 "health"
     RSPY_LOCAL_MODE=1 \
         run_local_service "../staging" "rs_server_staging.main:app" 8004 "_mgmt/ping"
 

services/frontend/resources/services.yml

@@ -37,6 +37,7 @@ info:
 
     <a href="${STAC_BROWSER_URL_ADGS}" target="_blank">ADGS</a> /
     <a href="${STAC_BROWSER_URL_CADIP}" target="_blank">CADIP</a> /
+    <a href="${STAC_BROWSER_URL_PRIP}" target="_blank">PRIP</a> /
     <a href="${STAC_BROWSER_URL_CATALOG}" target="_blank">Catalog</a>
 
     ---
@@ -51,6 +52,11 @@ services:
     change_tags:
       "": CADIP stations
       Filter Extension: CADIP (Filter Extension)
+  prip:
+    openapi_url: http://localhost:8005/prip/api
+    change_tags:
+      "": PRIP stations
+      Filter Extension: PRIP (Filter Extension)
   catalog:
     openapi_url: http://localhost:8003/catalog/api
     change_tags:

services/staging/rs_server_staging/processors/tasks.py

@@ -72,10 +72,8 @@ def streaming_task(  # pylint: disable=R0913, R0917
     Retry Mechanism:
         - Retries occur for network-related errors (`RequestException`) or S3 client errors
         (`ClientError`, `BotoCoreError`).
-        - The function waits before retrying, with the delay time increasing exponentially
-        (based on the `backoff_factor`).
-        - The backoff formula is `backoff_factor * (2 ** (attempt - 1))`, allowing progressively
-        longer wait times between retries.
+        - The function waits S3_RETRY_TIMEOUT seconds before retrying
+        - It keeps trying for S3_MAX_RETRIES times
     """
 
     logger_dask = logging.getLogger(__name__)
@@ -84,7 +82,6 @@ def streaming_task(  # pylint: disable=R0913, R0917
     product_url = asset_info.product_url
     s3_file = asset_info.s3_file
     bucket = asset_info.s3_bucket
-    # time.sleep(5)
     # get the retry timeout
     s3_retry_timeout = int(os.environ.get("S3_RETRY_TIMEOUT", S3_RETRY_TIMEOUT))
     # get the number of retries in case of failure