Raphael Pacheco
04/11/2023, 2:17 AMairbyte_instance = airbyte_resource.configured(
{
"host": "localhost",
"port": "8000",
"username": "airbyte",
"password": "password"
}
)
airbyte_assets = with_resources(
build_airbyte_assets(
connection_id="<my_connection_id>",
destination_tables=["<my_tbale>"],
asset_key_prefix=["stripe"]
),
{"airbyte": airbyte_instance}
)
claire
04/11/2023, 9:23 PMfrom dagster._core.definitions.load_assets_from_modules import assets_with_attributes
assets_with_group = assets_with_attributes(airbyte_assets, ...)
using this method: https://github.com/dagster-io/dagster/blob/a87f72cd1b568382f51d6f8590f7dd9ca0001b2[…]s/dagster/dagster/_core/definitions/load_assets_from_modules.pyRaphael Pacheco
04/13/2023, 3:11 PMclaire
04/13/2023, 6:07 PMsource_assets
and cacheable_assets
params, which should work fine.
Though warning is that since its not a public API, it might unexpectedly change or be removed. I'd recommend filing an issue to enable adding group names to airbyte assets.