https://dagster.io/ logo
Title
m

Micheal Ascah

05/25/2023, 2:13 PM
Has anyone run into this exception when trying to filter Fivetran connectors using
load_assets_from_fivetran_instance
?
fivetran_instance = FivetranResource(
    api_key=os.getenv("FIVETRAN_API_KEY"),
    api_secret=os.getenv("FIVETRAN_API_SECRET"),
    disable_schedule_on_trigger=False,
)

fivetran_assets = load_assets_from_fivetran_instance(
    fivetran_instance,
    connection_filter=lambda meta: "snowflake" in meta.name,
)
dagster.daemon.SensorDaemon - WARNING - Could not load location dagster_test to check for sensors due to the following error: TypeError: load_assets_from_fivetran_instance() got an unexpected keyword argument 'connection_filter'
r

rex

05/25/2023, 2:35 PM
you want to use
connector_filter
ah, the API string is wrong for that function! will fix
m

Micheal Ascah

05/25/2023, 3:29 PM
Thanks @rex! I was staring at the source for the function and my eyes glazed over this. I thought I was losing my mind 😄