Files
privateGPT/tests/settings/test_settings.py
Javier Martinez cd8ca2214a feat: resumable chat worker + tool worker + async tokenizer (#2298)
* 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 commit a2110f94a8.

* 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 commit 218b599c66)

# 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 commit fc5ec0f72a)

* fix: ruff

* fix: test

* fix: worker config

(cherry picked from commit 1371c275a1)

* 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>
2026-07-15 12:12:45 +02:00

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)