Make suppress_logs_and_warning CLI decorator return the wrapped result

airflow-core/src/airflow/utils/cli.py

@@ -462,28 +462,27 @@ def suppress_logs_and_warning(f: T) -> T:
     def _wrapper(*args, **kwargs):
         _check_cli_args(args)
         if args[0].verbose:
-            f(*args, **kwargs)
-        else:
-            from airflow._shared.logging.structlog import respect_stdlib_disable
-
-            with warnings.catch_warnings():
-                warnings.simplefilter("ignore")
-                logging.disable(logging.CRITICAL)
-
-                def drop(*_, **__):
-                    from structlog import DropEvent
-
-                    raise DropEvent()
-
-                old_fn = respect_stdlib_disable.__code__
-                respect_stdlib_disable.__code__ = drop.__code__
-                try:
-                    f(*args, **kwargs)
-                finally:
-                    # logging output again depends on the effective
-                    # levels of individual loggers
-                    logging.disable(logging.NOTSET)
-                    respect_stdlib_disable.__code__ = old_fn
+            return f(*args, **kwargs)
+        from airflow._shared.logging.structlog import respect_stdlib_disable
+
+        with warnings.catch_warnings():
+            warnings.simplefilter("ignore")
+            logging.disable(logging.CRITICAL)
+
+            def drop(*_, **__):
+                from structlog import DropEvent
+
+                raise DropEvent()
+
+            old_fn = respect_stdlib_disable.__code__
+            respect_stdlib_disable.__code__ = drop.__code__
+            try:
+                return f(*args, **kwargs)
+            finally:
+                # logging output again depends on the effective
+                # levels of individual loggers
+                logging.disable(logging.NOTSET)
+                respect_stdlib_disable.__code__ = old_fn
 
     return cast("T", _wrapper)
 

airflow-core/tests/unit/utils/test_cli_util.py

@@ -376,3 +376,13 @@ def test_should_enable_hot_reload(dev_flag, env_var, expected):
 
     with mock.patch.dict(os.environ, env, clear=True):
         assert cli.should_enable_hot_reload(args) is expected
+
+
+@pytest.mark.non_db_test_override
+@pytest.mark.parametrize("verbose", [True, False])
+def test_suppress_logs_and_warning_returns_wrapped_value(verbose):
+    @cli.suppress_logs_and_warning
+    def command(args):
+        return "result"
+
+    assert command(Namespace(verbose=verbose)) == "result"