John Mav
07/02/2020, 11:28 PMrequired_resource_keys
to a solid would it look something like
@solid(
required_resource_keys={'s3','database'}
)
def my_solid(context):
# stuff
And then the pipeline that invokes the solid would look something like
@pipeline(
mode_defs = [
ModeDefinition("test", resource_defs={'s3': s3_resource, 'database': postgres_resource})
]
)
def my_pipeline():
r = my_solid()
sandy
07/02/2020, 11:31 PMJohn Mav
07/02/2020, 11:46 PM