Evan O'Brien
07/21/2023, 5:43 PM@op(out=DynamicOut())
def get_configs (context: OpExecutionContext) -> SomeConfig:
for config in configs:
yield DynamicOutput(mapping_key=config_key, value=config)
@op(ins={
"data": In(input_manager_key="some_io_manager"),
"config": <Not sure what goes here>)
},
out=Out(io_manager_key="some_io_manager"))
def op_2 (context, data, config: SomeConfig):
alex
07/21/2023, 5:58 PMAPIJobScrapeConfig
a child of Config
? if so you just omit that from ins
Evan O'Brien
07/21/2023, 6:07 PM@graph_asset()
def example_asset():
return get_configs().map(op_2)
i receive a DagsterInvalidDefinitionError, saying the config has no way of being resolvedEvan O'Brien
07/21/2023, 6:12 PMalex
07/21/2023, 6:23 PMEvan O'Brien
07/21/2023, 6:23 PM