docs(agents/tools): TODO race on shared parquet output for concurrent /agent/run
Browse files- src/agents/tools.py +4 -0
src/agents/tools.py
CHANGED
|
@@ -102,6 +102,8 @@ def _make_eeg_executor(processed_dir: Path) -> Callable[[EEGPipelineInput], EEGP
|
|
| 102 |
from src.api.schemas import EEGRequest
|
| 103 |
from src.api import routes as api_routes
|
| 104 |
from fastapi import HTTPException
|
|
|
|
|
|
|
| 105 |
out_path = processed_dir / "eeg_features.parquet"
|
| 106 |
try:
|
| 107 |
response = api_routes.run_eeg(
|
|
@@ -129,6 +131,8 @@ def _make_mri_executor(processed_dir: Path) -> Callable[[MRIPipelineInput], MRIP
|
|
| 129 |
from src.api.schemas import MRIRequest
|
| 130 |
from src.api import routes as api_routes
|
| 131 |
from fastapi import HTTPException
|
|
|
|
|
|
|
| 132 |
out_path = processed_dir / "mri_features.parquet"
|
| 133 |
sites_csv = inp.sites_csv or str(Path(inp.input_dir) / "sites.csv")
|
| 134 |
try:
|
|
|
|
| 102 |
from src.api.schemas import EEGRequest
|
| 103 |
from src.api import routes as api_routes
|
| 104 |
from fastapi import HTTPException
|
| 105 |
+
# TODO(post-hackathon): per-call output path. Concurrent /agent/run
|
| 106 |
+
# invocations race on this file and clobber each other's MLflow runs.
|
| 107 |
out_path = processed_dir / "eeg_features.parquet"
|
| 108 |
try:
|
| 109 |
response = api_routes.run_eeg(
|
|
|
|
| 131 |
from src.api.schemas import MRIRequest
|
| 132 |
from src.api import routes as api_routes
|
| 133 |
from fastapi import HTTPException
|
| 134 |
+
# TODO(post-hackathon): per-call output path. Concurrent /agent/run
|
| 135 |
+
# invocations race on this file and clobber each other's MLflow runs.
|
| 136 |
out_path = processed_dir / "mri_features.parquet"
|
| 137 |
sites_csv = inp.sites_csv or str(Path(inp.input_dir) / "sites.csv")
|
| 138 |
try:
|