won
02/24/2023, 9:48 AMfrom dagster import asset, with_resources
from dagster_gcp.gcs import gcs_pickle_io_manager, gcs_resource
import pandas as pd
@asset
def asset1():
return pd.DataFrame()
@asset
def asset2(asset1):
return asset1[:5]
@repository
def repo():
return with_resources(
[asset1, asset2],
resource_defs={
"io_manager": gcs_pickle_io_manager.configured(
{"gcs_bucket": "my-cool-bucket", "gcs_prefix": "my-cool-prefix"}
),
"gcs": gcs_resource,
},
)
claire
02/24/2023, 9:26 PM