Logan Bonsignore
01/27/2023, 6:59 PMdefs = Definitions(
assets=load_assets_from_package_name('pipelines.pipeline'),
resources={
'io_manageesourcer': s3_pickle_io_manager.configured({'s3_bucket': {'env': 'S3_BUCKET_ETH'}}),
's3': s3_resource,
'snowflake': snowflake_resource(
config={
"account": {"env": "SNOWFLAKE_ACCOUNT"},
"user": {"env": "SNOWFLAKE_USER"},
"password": {"env": "SNOWFLAKE_PASSWORD"},
"warehouse": {"env": "SNOWFLAKE_WAREHOUSE"},
"database": {"env": "SNOWFLAKE_DATABASE_ETH"},
"schema": {"env": "SNOWFLAKE_SCHEMA_ETH"},
}
),
},
jobs=[export_all],
)