Skip to content

Explore

API endpoints for data exploration.

router = APIRouter(prefix='/api/explore', tags=['explore']) module-attribute

api_explore_run(request) async

Start an exploration run.

Source code in src/onesecondtrader/dashboard/routers/explore.py 
40
41
42
43
44
45
46
47
48
49
50
@router.post("/run")
async def api_explore_run(request: ExploreRequest) -> dict:
    """Start an exploration run."""
    if not request.symbols:
        return {"error": "No symbols selected"}
    if not request.indicators:
        return {"error": "No indicators selected"}
    ts = datetime.now(timezone.utc).strftime("%Y%m%d-%H%M%S")
    run_id = f"{ts}-{uuid.uuid4().hex[:8]}"
    enqueue_exploration(request, run_id)
    return {"run_id": run_id, "status": "queued"}

api_explore_status(run_id) async

Return the status of an exploration run.

Source code in src/onesecondtrader/dashboard/routers/explore.py 
53
54
55
56
57
58
59
60
61
@router.get("/status/{run_id}")
async def api_explore_status(run_id: str) -> dict:
    """Return the status of an exploration run."""
    with _jobs_lock:
        status = explore_jobs.get(run_id)
        progress = _explore_progress.get(run_id, 0.0)
    if status is None:
        return {"status": "unknown", "progress": 0.0}
    return {"status": status, "progress": progress}

api_explore_runs() async

Return recent exploration runs.

Source code in src/onesecondtrader/dashboard/routers/explore.py 
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
@router.get("/runs")
async def api_explore_runs() -> dict:
    """Return recent exploration runs."""
    try:
        conn_ctx = connect_runs()
    except FileNotFoundError:
        return {"runs": []}
    with conn_ctx as conn:
        cursor = conn.cursor()
        cursor.execute(
            """
            SELECT run_id, name, ts_start, ts_end, status, config, metadata
            FROM runs
            ORDER BY ts_start DESC
            """
        )
        rows = cursor.fetchall()
    runs = []
    for row in rows:
        config = json.loads(row[5]) if row[5] else {}
        if config.get("mode") != "exploration":
            continue
        metadata = json.loads(row[6]) if row[6] else None
        runs.append(
            {
                "run_id": row[0],
                "name": row[1],
                "ts_start": row[2],
                "ts_end": row[3],
                "status": row[4],
                "config": config,
                "metadata": metadata,
            }
        )
    return {"runs": runs}