Julius
04/20/2023, 8:06 AMfrom dagster import (
file_relative_path,
Definitions,
)
from dagster_fivetran import (
FivetranResource,
load_assets_from_fivetran_instance,
)
import os
from dotenv import load_dotenv
# load key from .env file
load_dotenv()
FIVETRAN_API_KEY = os.getenv("FIVETRAN_API_KEY")
FIVETRAN_API_SECRET = os.getenv("FIVETRAN_API_SECRET")
# Pull API key and secret from environment variables
fivetran_instance = FivetranResource(
api_key=FIVETRAN_API_KEY,
api_secret=FIVETRAN_API_SECRET,
)
fivetran_assets = load_assets_from_fivetran_instance(fivetran_instance)
# -----------------Definitions-----------------
# ---------------------------------------------
defs = Definitions(
jobs=[],
assets=[fivetran_assets],
sensors=[],
schedules=[],
)
and got this error:
dagster._core.errors.DagsterInvalidDefinitionError: Conflicting versions of resource with key 'fivetran' were provided to different assets. When constructing a job, all resource definitions provided to assets must match by reference equality for a given key.
I'm using dagster-fivetran version 0.19.0alex
04/20/2023, 5:49 PM