Raphael Pacheco
04/13/2023, 3:26 PMimport json
from dagster import (
asset,
Definitions,
load_assets_from_package_module
)
from dagster_dbt import load_assets_from_dbt_manifest
from dagster_airbyte_example.assets import airbyte
from .config.constants import DOMAIN, BI_OWNER
airbyte_assets = load_assets_from_package_module(
airbyte,
key_prefix="best_target"
)
manifest_file = "/home/raphael-pacheco/workspace/dagster-airbyte-example/best_target/target/manifest.json"
with open(manifest_file, encoding='utf-8') as f:
manifest = json.load(f)
dbt_assets = load_assets_from_dbt_manifest(
manifest,
key_prefix="best_target",
)
defs = Definitions(
assets=[*airbyte_assets] + dbt_assets,
)
What am I doing wrong?
Thanks in advanceTim Castillo
04/13/2023, 3:33 PMRaphael Pacheco
04/13/2023, 6:27 PM