diff --git a/compose.test-cfcore.yml b/compose.test-cfcore.yml index 278df8f..eea3d34 100644 --- a/compose.test-cfcore.yml +++ b/compose.test-cfcore.yml @@ -22,10 +22,14 @@ services: - "8516:8501" volumes: - /devl/job-seeker:/devl/job-seeker + - /devl/job-seeker/config:/app/config + - /devl/job-seeker/config/llm.docker.yaml:/app/config/llm.yaml:ro + - /devl/job-seeker/config/user.docker.yaml:/app/config/user.yaml:ro environment: - STAGING_DB=/devl/job-seeker/staging.db - PYTHONUNBUFFERED=1 - STREAMLIT_SERVER_BASE_URL_PATH= + - CF_ORCH_URL=http://host.docker.internal:7700 extra_hosts: - "host.docker.internal:host-gateway" restart: "no" diff --git a/scripts/task_scheduler.py b/scripts/task_scheduler.py index 824ae85..0867221 100644 --- a/scripts/task_scheduler.py +++ b/scripts/task_scheduler.py @@ -15,6 +15,7 @@ Public API (unchanged — callers do not need to change): from __future__ import annotations import logging +import os import threading from pathlib import Path from typing import Callable, Optional @@ -112,6 +113,10 @@ class TaskScheduler(_CoreTaskScheduler): "defaulting to 0.0 GB (unlimited concurrency for this type)", t ) + coordinator_url = os.environ.get( + "CF_ORCH_URL", "http://localhost:7700" + ).rstrip("/") + super().__init__( db_path=db_path, run_task_fn=run_task_fn, @@ -119,6 +124,8 @@ class TaskScheduler(_CoreTaskScheduler): vram_budgets=budgets, available_vram_gb=available_vram, max_queue_depth=max_depth, + coordinator_url=coordinator_url, + service_name="peregrine", ) def enqueue(