[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci
This commit is contained in:
pre-commit-ci[bot] 2026-07-22 13:11:43 +00:00
commit 516e338d1a
3 changed files with 10 additions and 13 deletions

View file

@ -672,9 +672,7 @@ async def record_import_ledger(
@router.delete("")
async def clear_history(
request: Request, current_subject: str = Depends(get_current_subject)
):
async def clear_history(request: Request, current_subject: str = Depends(get_current_subject)):
_cancel_active_research(request, [thread["id"] for thread in list_chat_threads()])
clear_chat_history()
return {"status": "deleted"}

View file

@ -233,9 +233,7 @@ def _sanitize_config(payload: CreateResearchRun, thread: dict) -> dict:
# container both evades the sensitive-key scan when its inner keys are unlisted (e.g.
# {"kb_id": {"auth": "sk-..."}}) and would reach retrieval code that expects a scalar scope
# id, so reject any non-scalar value outright.
non_scalar = any(
isinstance(value, (dict, list, tuple)) for value in rag_scope.values()
)
non_scalar = any(isinstance(value, (dict, list, tuple)) for value in rag_scope.values())
if unknown_rag or non_scalar or _contains_sensitive_key(rag_scope):
raise HTTPException(status_code = 400, detail = "Unsupported or sensitive ragScope field")
budgets = {

View file

@ -686,9 +686,7 @@ def test_delete_thread_cancels_active_research_run(research_home):
cancelled: list[str] = []
request = SimpleNamespace(
app = SimpleNamespace(
state = SimpleNamespace(
research_supervisor = SimpleNamespace(cancel = cancelled.append)
)
state = SimpleNamespace(research_supervisor = SimpleNamespace(cancel = cancelled.append))
)
)
chat_history._cancel_active_research(request, ["thread-1"])
@ -1265,13 +1263,16 @@ def test_planner_prompt_shields_untrusted_conversation(research_home, monkeypatc
)
_create(user_message_id = "user-inj", assistant_message_id = None)
supervisor = worker.ResearchSupervisor(
SimpleNamespace(state = SimpleNamespace(server_port = 1))
)
supervisor = worker.ResearchSupervisor(SimpleNamespace(state = SimpleNamespace(server_port = 1)))
captured: dict = {}
async def fake_stream_completion(
run, messages, *, json_mode = False, report_progress = True, **kwargs
run,
messages,
*,
json_mode = False,
report_progress = True,
**kwargs,
):
captured["planner"] = messages[1]["content"]
return json.dumps(_plan()), "Planned.", "stop"