diff --git a/src/pyflowx/runner.py b/src/pyflowx/runner.py index 039f350..e80cc42 100644 --- a/src/pyflowx/runner.py +++ b/src/pyflowx/runner.py @@ -161,7 +161,7 @@ class CliRunner: _ = parser.add_argument( "--strategy", choices=list(get_args(Strategy)), - default="sequential", + default=self.strategy, help="执行策略 (默认: %(default)s)", ) _ = parser.add_argument( diff --git a/tests/test_runner.py b/tests/test_runner.py index f40e983..6be2d69 100644 --- a/tests/test_runner.py +++ b/tests/test_runner.py @@ -167,10 +167,10 @@ class TestCliRunnerParser: def test_parser_strategy_default(self) -> None: """--strategy 默认值应与构造时一致.""" - runner = px.CliRunner({"clean": _echo_graph()}, "async") + runner = px.CliRunner({"clean": _echo_graph()}, strategy="async") parser = runner.create_parser() parsed = parser.parse_args(["clean"]) - assert parsed.strategy == "sequential" + assert parsed.strategy == "async" def test_parser_has_dry_run_flag(self) -> None: """解析器应有 --dry-run 标志."""