feat(isr): wire mission param through API/background pipeline, add openai dep

- Add mission param to /detect/async endpoint
- Pass mission to JobInfo constructor
- Spawn ISR assessor loop in background.py when mission is set
- Cancel ISR task on job completion (final assessment in handler)
- Add openai>=1.0.0 to requirements.txt

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

app.py

@@ -315,6 +315,7 @@ async def detect_async_endpoint(
     depth_scale: float = Form(25.0),
     enable_depth: bool = Form(False),
     step: int = Form(7),
+    mission: str = Form(None),
 ):
     _ttfs_t0 = time.perf_counter()
 
@@ -389,6 +390,7 @@ async def detect_async_endpoint(
         first_frame_depth_path=str(first_frame_depth_path),
         step=step,
         ttfs_t0=_ttfs_t0,
+        mission=mission,
     )
     get_job_storage().create(job)
     asyncio.create_task(process_video_async(job_id))

jobs/background.py

@@ -6,6 +6,7 @@ from jobs.models import JobStatus
 from jobs.storage import get_job_storage
 from jobs.streaming import create_stream, remove_stream
 from inference import run_inference, run_grounded_sam2_tracking
+from models.isr.loop import run_isr_assessor_loop
 
 
 async def process_video_async(job_id: str) -> None:
@@ -18,11 +19,17 @@ async def process_video_async(job_id: str) -> None:
     depth_path = None
     depth_error = None
     partial_success = False
+    isr_task = None
 
     # Create stream for live view
     stream_queue = create_stream(job_id)
 
     try:
+        # Start ISR assessor if mission is provided
+        if job.mission:
+            isr_task = asyncio.create_task(
+                run_isr_assessor_loop(job_id, job.mission)
+            )
         # Run detection or segmentation first
         if job.mode == "segmentation":
             detection_path = await asyncio.to_thread(
@@ -76,6 +83,14 @@ async def process_video_async(job_id: str) -> None:
                  depth_path = detection_path
                  logging.info("Depth estimation included in main video for job %s", job_id)
 
+        # Stop ISR assessor (final assessment runs in cancellation handler)
+        if isr_task and not isr_task.done():
+            isr_task.cancel()
+            try:
+                await isr_task
+            except asyncio.CancelledError:
+                pass
+
         # Mark as completed (with or without depth)
         storage.update(
             job_id,

requirements.txt

@@ -15,3 +15,4 @@ hydra-core>=1.3.2
 iopath>=0.1.10
 psutil
 dill
+openai>=1.0.0