Dmitry Mogilevsky
06/14/2022, 8:51 PMop
but based on the documentation I've read so far I have a feeling that there's a way to do this using defined assets and io managers. Is there a concrete example of this somewhere? Thanks, and sorry for the half-baked question.Sashikanth Dareddy
06/14/2022, 8:59 PMDmitry Mogilevsky
06/14/2022, 9:06 PMclaire
06/14/2022, 9:13 PMDmitry Mogilevsky
06/14/2022, 10:06 PM@repository
def my_repository():
return [
asset1,
asset2,
asset3,
job1_schedule,
job2_sensor,
job3,
]
dagster.core.errors.DagsterInvalidDefinitionError: Bad return value from repository construction function: all elements of list must be of type JobDefinition, GraphDefinition, PipelineDefinition, PartitionSetDefinition, ScheduleDefinition, or SensorDefinition. Got value of type <class 'dagster.core.asset_defs.assets.AssetsDefinition'> at index 1.
claire
06/14/2022, 10:21 PMDmitry Mogilevsky
06/14/2022, 10:23 PM