Corrected non-sleep behaviour for 15 minutes

main.py

@@ -41,9 +41,8 @@ SDK_MAX_BODY_BYTES_extended = int(os.getenv("SDK_MAX_BODY_BYTES_extended", "1250
 
 # How long to wait for upstream (API) response; long runs may need 30+ min (1800+)
 UPSTREAM_TIMEOUT = float(os.getenv("UPSTREAM_TIMEOUT", "900"))  # 15 minutes
-# While waiting for a response: send secure_ping to upstream every N seconds; if SELF_URL set, also ping self every SELF_PING_INTERVAL so this Space stays awake
-PING_UPSTREAM_INTERVAL = float(os.getenv("PING_UPSTREAM_INTERVAL", "270"))
-SELF_PING_INTERVAL = float(os.getenv("SELF_PING_INTERVAL", "120"))
+# While waiting for a response: every PING_INTERVAL seconds we ping the backend (secure_ping) and, if SELF_URL is set, we also ping ourselves (keep-alive) so this Space stays awake
+PING_INTERVAL = float(os.getenv("PING_INTERVAL", "270"))
 
 # Early global body-size guard (runs before routes)
 @app.middleware("http")
@@ -102,11 +101,10 @@ async def _ping_upstream_loop(ping_url: str, headers: dict, interval: float, sel
             pass
 
 def _start_ping_task(ping_url: str, headers: dict, self_url: str = ""):
-    """Start background ping task. If SELF_URL set, uses SELF_PING_INTERVAL and pings self + backend; else PING_UPSTREAM_INTERVAL, backend only."""
-    interval = (SELF_PING_INTERVAL if self_url and SELF_PING_INTERVAL > 0 else PING_UPSTREAM_INTERVAL) or PING_UPSTREAM_INTERVAL
-    if interval <= 0:
+    """Start background ping task: every PING_INTERVAL seconds ping backend and, if self_url set, also ping self."""
+    if PING_INTERVAL <= 0:
         return None
-    return asyncio.create_task(_ping_upstream_loop(ping_url, headers, interval, self_url))
+    return asyncio.create_task(_ping_upstream_loop(ping_url, headers, PING_INTERVAL, self_url))
 
 async def _cancel_ping_task(task: asyncio.Task | None):
     if task is None:
@@ -132,7 +130,7 @@ async def _forward(path: str, method: str = "GET", json_body=None, user_token: s
     Forward request to the PRIVATE Space:
       - 'Authorization: Bearer <HF_TOKEN>' to pass HF private gate
       - 'X-API-Key: <dt+...>' so your private app can validate the user token
-    While waiting for the result, sends secure_ping to upstream every PING_UPSTREAM_INTERVAL seconds.
+    While waiting, every PING_INTERVAL seconds: secure_ping to backend and, if SELF_URL set, ping self (keep-alive).
     """
     url = f"{UPSTREAM_URL}{path}"
     headers = {
@@ -157,8 +155,7 @@ async def _forward(path: str, method: str = "GET", json_body=None, user_token: s
             r = await client.request(method, url, headers=headers, json=json_body)
 
     request_task = asyncio.create_task(do_request())
-    interval = PING_UPSTREAM_INTERVAL if PING_UPSTREAM_INTERVAL > 0 else 0.0
-    wait_sec = (SELF_PING_INTERVAL if SELF_URL and SELF_PING_INTERVAL > 0 else interval) or interval
+    wait_sec = PING_INTERVAL if PING_INTERVAL > 0 else 0.0
     try:
         while not request_task.done():
             if wait_sec <= 0:
@@ -316,8 +313,7 @@ async def _forward_multipart_json(path: str, files=None, data=None, user_token:
             r = await client.request(method, url, headers=headers, files=files, data=data)
 
     request_task = asyncio.create_task(do_request())
-    interval = PING_UPSTREAM_INTERVAL if PING_UPSTREAM_INTERVAL > 0 else 0.0
-    wait_sec = (SELF_PING_INTERVAL if SELF_URL and SELF_PING_INTERVAL > 0 else interval) or interval
+    wait_sec = PING_INTERVAL if PING_INTERVAL > 0 else 0.0
     try:
         while not request_task.done():
             if wait_sec <= 0: