Hi folks, is it possible to setup airbyte assets as an upstream of another asset?

@ben do you have a repo for the demo of

dagster-airbyte

as you showed in the ‘Data ingestion as code’ video?

Thanks a lot! @Fraser Marlow any chance you know is there an option to also define the input asset for an airbyte? I’m defining airbyte asset using

ab_assets_movies = with_resources(
    build_airbyte_assets(
        connection_id="***",
        destination_tables=["destination_tables"],
        asset_key_prefix=["asset_key_prefix"]
    ),
    {"airbyte": my_airbyte_resource},
)

or with

load_assets_from_airbyte_instance

but I cant find a way to define an AssetIn or “source_asset_key” for it. For example say I have another python asset which I want to set up as an upstream for this airbyte.

Sorry, I am not very technically proficient and when I try to help out, I usually cause more confusion. I will let @ben advise, or I recommend putting the question back in the main #dagster-support channel top-level thread.

Hi Anton, sorry for the delayed response! You should be able to pass

upstream_assets

to

build_airbyte_assets

, this takes a list of asset keys where you can add your source asset keys

please @beni need an example of this, i try to do it in dagster but no success, just error after error.