19913d85-f662-4518-a9a1-7adc1793dfd4.png){kind=small}
Hello community,
I am trying to load my airbyte c...
# integration-airbytes
Selim Raboudi
02/22/2024, 9:52 PMHello 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'>.Selim Raboudi
02/22/2024, 9:52 PMHere 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}
)Selim Raboudi
02/23/2024, 12:15 AMAnswer here: https://dagster.slack.com/archives/C066HKS7EG1/p1708641124648139
TLDR: don’t put airbyte_assets in brackets in the Definitions call:
airbyte_definitions = Definitions(4 Views