fix: extend validation for --factory param

faststream/cli/main.py

@@ -155,7 +155,7 @@ def run(
                 workers=workers,
             ).run()
         else:
-            args[1]["workers"] = workers
+            args[1]["workers"] = workers  # type: ignore[assignment]
             _run(*args)
 
     else:

faststream/cli/utils/imports.py

@@ -1,17 +1,15 @@
 import importlib
 from importlib.util import module_from_spec, spec_from_file_location
 from pathlib import Path
-from typing import TYPE_CHECKING, Tuple
+from typing import Tuple
 
 import typer
 
+from faststream._internal.application import Application
 from faststream.exceptions import SetupError
 
-if TYPE_CHECKING:
-    from faststream.app import FastStream
 
-
-def try_import_app(module: Path, app: str) -> "FastStream":
+def try_import_app(module: Path, app: str) -> "Application":
     """Tries to import a FastStream app from a module."""
     try:
         app_object = import_object(module, app)
@@ -71,7 +69,7 @@ def import_from_string(
     import_str: str,
     *,
     is_factory: bool = False,
-) -> Tuple[Path, "FastStream"]:
+) -> Tuple[Path, "Application"]:
     module_path, instance = _import_obj_or_factory(import_str)
 
     if is_factory:
@@ -80,10 +78,13 @@ def import_from_string(
         else:
             raise typer.BadParameter(f'"{instance}" is not a factory')
 
+    if callable(instance) and not is_factory and not isinstance(instance, Application):
+        raise typer.BadParameter("Please, use --factory option for callable object")
+
     return module_path, instance
 
 
-def _import_obj_or_factory(import_str: str) -> Tuple[Path, "FastStream"]:
+def _import_obj_or_factory(import_str: str) -> Tuple[Path, "Application"]:
     """Import FastStream application from module specified by a string."""
     if not isinstance(import_str, str):
         raise typer.BadParameter("Given value is not of type string")

tests/cli/test_run.py

@@ -4,12 +4,16 @@
 import pytest
 from typer.testing import CliRunner
 
+from faststream._internal.application import Application
+from faststream.app import FastStream
 from faststream.asgi import AsgiFastStream
 from faststream.cli.main import cli as faststream_app
 
 
-def test_run_as_asgi(runner: CliRunner):
-    app = AsgiFastStream()
+@pytest.mark.parametrize(
+    "app", [pytest.param(FastStream()), pytest.param(AsgiFastStream())]
+)
+def test_run(runner: CliRunner, app: Application):
     app.run = AsyncMock()
 
     with patch(
@@ -33,8 +37,8 @@ def test_run_as_asgi(runner: CliRunner):
 
 
 @pytest.mark.parametrize("workers", [1, 2, 5])
-def test_run_as_asgi_with_workers(runner: CliRunner, workers: int):
-    app = AsgiFastStream()
+@pytest.mark.parametrize("app", [pytest.param(AsgiFastStream())])
+def test_run_as_asgi_with_workers(runner: CliRunner, workers: int, app: Application):
     app.run = AsyncMock()
 
     with patch(
@@ -61,8 +65,10 @@ def test_run_as_asgi_with_workers(runner: CliRunner, workers: int):
         assert result.exit_code == 0
 
 
-def test_run_as_asgi_callable(runner: CliRunner):
-    app = AsgiFastStream()
+@pytest.mark.parametrize(
+    "app", [pytest.param(FastStream()), pytest.param(AsgiFastStream())]
+)
+def test_run_as_factory(runner: CliRunner, app: Application):
     app.run = AsyncMock()
 
     app_factory = Mock(return_value=app)
@@ -88,3 +94,29 @@ def test_run_as_asgi_callable(runner: CliRunner):
             logging.INFO, {"host": "0.0.0.0", "port": "8000"}
         )
         assert result.exit_code == 0
+
+
+@pytest.mark.parametrize(
+    "app", [pytest.param(FastStream()), pytest.param(AsgiFastStream())]
+)
+def test_run_app_like_factory_but_its_fake(runner: CliRunner, app: Application):
+    app.run = AsyncMock()
+
+    with patch(
+        "faststream.cli.utils.imports._import_obj_or_factory",
+        return_value=(None, app),
+    ):
+        result = runner.invoke(
+            faststream_app,
+            [
+                "run",
+                "faststream:app",
+                "--host",
+                "0.0.0.0",
+                "--port",
+                "8000",
+                "--factory",
+            ],
+        )
+        app.run.assert_not_called()
+        assert result.exit_code != 0