amanmurari commited on
Commit
48e7c77
·
verified ·
1 Parent(s): d51a28d

Upload folder using huggingface_hub

Browse files
Files changed (1) hide show
  1. inference.py +18 -3
inference.py CHANGED
@@ -48,8 +48,12 @@ except ImportError:
48
  # Configuration - CRITICAL: Use os.environ[] with NO fallbacks per validator
49
  # ---------------------------------------------------------------------------
50
 
51
- MODEL_NAME = os.environ.get("MODEL_NAME", "gpt-4o-mini")
52
- SERVER_URL = os.environ.get("SERVER_URL", "http://localhost:8000")
 
 
 
 
53
 
54
  SEED = 42
55
  MAX_TOKENS = 64
@@ -265,7 +269,18 @@ def run_task(task: str, client: OpenAI) -> None:
265
  # ---------------------------------------------------------------------------
266
 
267
  def main() -> None:
268
- client = OpenAI(base_url=os.environ["API_BASE_URL"], api_key=os.environ["API_KEY"])
 
 
 
 
 
 
 
 
 
 
 
269
 
270
  for task in ["basic_flow", "emergency_priority", "dynamic_scenarios"]:
271
  run_task(task, client)
 
48
  # Configuration - CRITICAL: Use os.environ[] with NO fallbacks per validator
49
  # ---------------------------------------------------------------------------
50
 
51
+ API_BASE_URL = os.getenv("API_BASE_URL", "http://localhost:8000")
52
+ MODEL_NAME = os.getenv("MODEL_NAME", "gpt-4o-mini")
53
+ HF_TOKEN = os.getenv("HF_TOKEN")
54
+ LOCAL_IMAGE_NAME = os.getenv("LOCAL_IMAGE_NAME")
55
+
56
+ SERVER_URL = os.getenv("SERVER_URL", "http://localhost:8000")
57
 
58
  SEED = 42
59
  MAX_TOKENS = 64
 
269
  # ---------------------------------------------------------------------------
270
 
271
  def main() -> None:
272
+ client = OpenAI(base_url=API_BASE_URL, api_key=HF_TOKEN or "dummy-key")
273
+
274
+ import time
275
+ # Prevent Phase 2 unhandled connection exception by waiting for the server
276
+ for _ in range(15):
277
+ try:
278
+ r = _http.get(f"{SERVER_URL.rstrip('/')}/health", timeout=2)
279
+ if r.status_code == 200:
280
+ break
281
+ except Exception:
282
+ pass
283
+ time.sleep(2)
284
 
285
  for task in ["basic_flow", "emergency_priority", "dynamic_scenarios"]:
286
  run_task(task, client)