https://dagster.io/ logo
#ask-community
Title
# ask-community
j

James Rosenthal

02/07/2023, 11:19 PM
Hi all! I am trying to set up an Airbyte Connection in Dagster with a Postgres source and a Snowflake Destination. I started with the assets_modern_data_stack template, which already shows a clear format for the Postgres Source config, but not a Snowflake Destination. When I tried to write a config of the same format for a Snowflake Destination:
from dagster_snowflake.utils import get_conn_string as get_conn_string_sf
I got the error:
ModuleNotFoundError: No module named 'dagster_snowflake.utils'
After reading through the dagster-snowflake documentation (https://docs.dagster.io/_modules/dagster_snowflake/resources) , it looked like I needed dagster_snowflake.resources instead. When I tried:
from dagster_snowflake.resources import get_connection as get_conn_string_sf
I got the error:
ImportError: cannot import name 'get_connection' from 'dagster_snowflake.resources' (/opt/homebrew/lib/python3.10/site-packages/dagster_snowflake/resources.py)
Is there something that I should be doing differently? Is there a good template for creating an Airbyte Snowflake destination? Thanks!
🤖 1
Disregard this thread. I am now trying the approach here, but running into similar issues: https://dagster.slack.com/archives/C01U954MEER/p1675881639360499
4 Views