fix: compose configured sources for local cli target

This commit is contained in:
lda
2026-06-15 04:37:54 +07:00 Verified
parent e0ac7860d9
commit 766f5f0a57
2 changed files with 8 additions and 8 deletions
+2 -2
View File
@@ -26,7 +26,7 @@ from wf_config import (
from wf_mcp.broker import build_service_from_config, load_broker_config from wf_mcp.broker import build_service_from_config, load_broker_config
from wf_mcp.broker.service import WfMcpService from wf_mcp.broker.service import WfMcpService
from wf_mcp.broker.service.workflow_operation_context import context_from_service from wf_mcp.broker.service.workflow_operation_context import context_from_service
from wf_server import build_local_static_workflow_server from wf_server.config import build_workflow_server_from_workflow_config
from wf_transport_rpc_http import RpcWorkflowApiClient from wf_transport_rpc_http import RpcWorkflowApiClient
@@ -151,7 +151,7 @@ def load_cli_context(
store = config.server.workflow_store store = config.server.workflow_store
if not isinstance(store, FilesystemStoreConfig): if not isinstance(store, FilesystemStoreConfig):
raise ValueError("local CLI target currently requires filesystem store") raise ValueError("local CLI target currently requires filesystem store")
server = build_local_static_workflow_server(store.root) server = build_workflow_server_from_workflow_config(config)
return CliContext( return CliContext(
config_path=resolved_config_path, config_path=resolved_config_path,
service=None, service=None,
+6 -6
View File
@@ -16,7 +16,7 @@ from wf_cli.context import (
rpc_timeout_from_context, rpc_timeout_from_context,
rpc_url_from_context, rpc_url_from_context,
) )
from wf_server import build_local_static_workflow_server from wf_server.config import build_workflow_server_from_workflow_config
def _typer_context(obj: object | None) -> typer.Context: def _typer_context(obj: object | None) -> typer.Context:
@@ -177,13 +177,13 @@ def test_load_cli_context_local_uses_workflow_store_override(
) )
captured: dict[str, object] = {} captured: dict[str, object] = {}
def fake_build_local_static_workflow_server(root): def fake_build_workflow_server_from_workflow_config(config):
captured["store_root"] = root captured["store_root"] = config.server.workflow_store.root
return build_local_static_workflow_server(tmp_path / "actual") return build_workflow_server_from_workflow_config(config)
monkeypatch.setattr( monkeypatch.setattr(
"wf_cli.context.build_local_static_workflow_server", "wf_cli.context.build_workflow_server_from_workflow_config",
fake_build_local_static_workflow_server, fake_build_workflow_server_from_workflow_config,
) )
context = load_cli_context(config_path) context = load_cli_context(config_path)