HI Guys, I need help with a

dbtShellTask

. The issue I have is that I have a handler which sends notifications with details on the failing flows but when dbt task fails with return code 1, all i get is

'Command failed with exit code 1'

is there a way to capture in a variable the logs of a failed shell task to then process them and display them using the handler?

Hey @Andres! Since

DbtShellTask

subclasses

ShellTask

, I believe that you can use the

steam_output

option to log the output of the command that you’re running. Here’s a link to the

ShellTask

docs for more info: https://docs.prefect.io/api/latest/tasks/shell.html#shelltask.

We have quite a lot of resources about dbt collected under the dbt tag on Discourse if you are interested, e.g. this post dives deeper into it, but you can use those two arguments to capture logs and stdout from dbt runs:

dbt = DbtShellTask(
    return_all=True,
    log_stdout=True, ...)

my bad, I missed that the exception contains the logs on the result variable