mirror of
https://github.com/imartinez/privateGPT.git
synced 2026-07-17 01:48:03 +00:00
* fix: avoid to block the loop * fix: blocks in expansion * fix: remove maximum concurrent users ... * fix: multiplexer * fix: readers * fix: more fixes ... * fix: impl * feat: tool scheduler * feat: add adaptative * feat: add chat worker * fix: max * feat: add chat/tools workers * fix: mypy * feat: add generic scheduler * fix: get result * feat: do serializable the tool executor * fix: tools * fix: config * fix: config * fix: args * fix: config * fix: serializer * Revert "fix: blocks in expansion" This reverts commita2110f94a8. * fix: unify all logic * feat: add ingestion scheduler * fix: settings * fix: config * feat: add arq worker to chat * fix: arq worker * fix: add nest * fix: mypy * fix: await * fix: script stress * fix: tokenizer * fix: chat scheduler * fix: mypy * fix: add async tokenizer * fix: improve condense * fix: tool scheduler * feat: add initial real async chat worker * fix: mypy * fix: do resumable local executor ... ... ... fix: revert usleess changes fix: remove parent chat job fix: refactor fix: loop ref: rename models fix: chat engine fix: mypy ... ... ... fix: fix deps * fix: tests * fix: tests * ... * fix: stream * fix: config * fix: scheduler * Potential fix for pull request finding Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> * Potential fix for pull request finding Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> * Handle PGPT_WORKER_MODE=celery in health check worker status * fix: cancel * fix: arch * fix: test ingestion * fix: deserialization of chat messages * fix: broken results * fix: mypy * fix: test * fix: config * fix: remove arq tool worker * fix: output cls * fix: preserve early resumable tool callbacks * fix: preserve async tool result order * refactor: address worker PR review comments * fix: mypy * test: colocate ARQ chat enqueue coverage * fix: remove redis from tests * test: isolate chat mocks and cancellation timing * fix: tests (cherry picked from commit218b599c66) # Conflicts: # tests/server/chat/anthropic/test_anthropic_client.py # tests/server/chat/anthropic/test_langchain_anthropic.py # tests/server/chat/test_chat_knowledge_revamp.py # tests/server/chat/test_chat_routes.py # tests/server/chat/test_chat_routes_skills_integration.py * fix: tests (cherry picked from commitfc5ec0f72a) * fix: ruff * fix: test * fix: worker config (cherry picked from commit1371c275a1) * fix: principal * test: remove flaky chat cancellation assertion --------- Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
76 lines
2.1 KiB
Python
76 lines
2.1 KiB
Python
import pytest
|
|
|
|
from private_gpt.settings.settings import Settings, settings
|
|
from private_gpt.settings.settings_loader import merge_settings
|
|
from tests.fixtures.mock_injector import MockInjector, unsafe_settings
|
|
|
|
|
|
def test_settings_are_loaded_and_merged() -> None:
|
|
assert settings().server.env_name == "test"
|
|
|
|
|
|
def test_settings_can_be_overriden(injector: MockInjector) -> None:
|
|
injector.bind_settings({"server": {"env_name": "overriden"}})
|
|
mocked_settings = injector.get(Settings)
|
|
assert mocked_settings.server.env_name == "overriden"
|
|
|
|
|
|
def test_chat_scheduler_rejects_unsupported_celery_mode() -> None:
|
|
merged = merge_settings(
|
|
[
|
|
unsafe_settings,
|
|
{
|
|
"scheduler": {"chat": {"mode": "celery"}},
|
|
"stream": {"broker": "redis"},
|
|
"celery": {"use_workers": True},
|
|
},
|
|
]
|
|
)
|
|
|
|
with pytest.raises(ValueError, match=r"Unsupported scheduler\.chat\.mode='celery'"):
|
|
Settings(**merged)
|
|
|
|
|
|
def test_arq_chat_scheduler_requires_redis_stream_backend() -> None:
|
|
merged = merge_settings(
|
|
[
|
|
unsafe_settings,
|
|
{
|
|
"scheduler": {"chat": {"mode": "arq"}},
|
|
"stream": {"broker": "memory"},
|
|
},
|
|
]
|
|
)
|
|
|
|
with pytest.raises(ValueError, match=r"stream\.broker=redis"):
|
|
Settings(**merged)
|
|
|
|
|
|
def test_celery_tool_scheduler_requires_arq_chat() -> None:
|
|
merged = merge_settings(
|
|
[
|
|
unsafe_settings,
|
|
{
|
|
"scheduler": {
|
|
"chat": {"mode": "local"},
|
|
"tools": {"mode": "celery"},
|
|
},
|
|
},
|
|
]
|
|
)
|
|
|
|
with pytest.raises(ValueError, match=r"scheduler\.chat\.mode='arq'"):
|
|
Settings(**merged)
|
|
|
|
|
|
def test_tool_scheduler_rejects_unsupported_arq_mode() -> None:
|
|
merged = merge_settings(
|
|
[
|
|
unsafe_settings,
|
|
{"scheduler": {"tools": {"mode": "arq"}}},
|
|
]
|
|
)
|
|
|
|
with pytest.raises(ValueError, match=r"Unsupported scheduler\.tools\.mode='arq'"):
|
|
Settings(**merged)
|