diff --git a/elementary/clients/dbt/dbt_runner.py b/elementary/clients/dbt/dbt_runner.py index de9004ff7..4dfef2a12 100644 --- a/elementary/clients/dbt/dbt_runner.py +++ b/elementary/clients/dbt/dbt_runner.py @@ -172,6 +172,7 @@ def run( full_refresh: bool = False, vars: Optional[dict] = None, quiet: bool = False, + capture_output: bool = False, ) -> bool: command_args = ["run"] if full_refresh: @@ -181,7 +182,10 @@ def run( if select: command_args.extend(["-s", select]) success, _ = self._run_command( - command_args=command_args, vars=vars, quiet=quiet + command_args=command_args, + vars=vars, + quiet=quiet, + capture_output=capture_output, ) return success @@ -190,12 +194,16 @@ def test( select: Optional[str] = None, vars: Optional[dict] = None, quiet: bool = False, + capture_output: bool = False, ) -> bool: command_args = ["test"] if select: command_args.extend(["-s", select]) success, _ = self._run_command( - command_args=command_args, vars=vars, quiet=quiet + command_args=command_args, + vars=vars, + quiet=quiet, + capture_output=capture_output, ) return success