clesa
03/07/2024, 10:49 AMfrom pathlib import Path
from prefect import flow
from prefect_dbt.cli.commands import trigger_dbt_cli_command, DbtCliProfile, DbtCoreOperation
PROJECT_DIR = Path(__file__).parent.parent / 'datawarehouse'
DBT_PROJECT_DIR = PROJECT_DIR / 'dbt_project.yml'
PROFILES_DIR = PROJECT_DIR / 'profiles.yml'
@flow(log_prints=True)
def dbt_model():
result = DbtCoreOperation(
commands=["dbt debug"],
project_dir=DBT_PROJECT_DIR,
profiles_path=PROFILES_DIR,
).run()
return result
if __name__ == "__main__":
dbt_model()
clesa
03/07/2024, 10:51 AMthe error:
decoded = self._decoder.decode(chunk)
^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "<frozen codecs>", line 322, in decode
UnicodeDecodeError: 'utf-8' codec can't decode byte 0x82 in position 156: invalid start byte
11:16:36.933 | ERROR | Flow run 'artichoke-cockatoo' - Finished in state Failed("Flow run encountered an exception. UnicodeDecodeError: 'utf-8' codec can't decode byte 0x82 in position 156: invalid start byte")