https://dagster.io/ logo
#integration-airbyte
Title
# integration-airbyte
s

Selim Raboudi

02/22/2024, 9:52 PM
Hello community, I am trying to load my airbyte connections as assets in my dagster project. I have followed the official doc, Using Airbyte Cloud with Dagster, but keep running in the following error:
dagster._check.CheckError: Member of iterable mismatches type. Expected (<class 'dagster._core.definitions.assets.AssetsDefinition'>, <class 'dagster._core.definitions.source_asset.SourceAsset'>, <class 'dagster._core.definitions.cacheable_assets.CacheableAssetsDefinition'>). Got [<dagster._core.definitions.assets.AssetsDefinition object at 0x111f27e50>] of type <class 'list'>.
Has anyone faced the same issue ? (code in thread)
Here is my code:
Copy code
from dagster_airbyte import build_airbyte_assets
from dagster_airbyte import AirbyteCloudResource
from dagster import EnvVar
from dagster import Definitions

airbyte_assets = build_airbyte_assets(
    connection_id="4842929b-7169-4024-be39-fd6ff12fZHE4",
    destination_tables=["deals", "contacts"],
)

airbyte_instance = AirbyteCloudResource(api_key=EnvVar("AIRBYTE_API_KEY"))

airbyte_definitions = Definitions(
    assets=[airbyte_assets], resources={"airbyte": airbyte_instance}
)
Answer here: https://dagster.slack.com/archives/C066HKS7EG1/p1708641124648139 TLDR: don’t put airbyte_assets in brackets in the Definitions call:
airbyte_definitions = Definitions(
assets=airbyte_assets, resources={“airbyte”: airbyte_instance} )
2 Views