Sebastian Napiorkowski
09/15/2021, 3:42 PM@solid(input_defs=[InputDefinition(name="a_list")],
output_defs=[DynamicOutputDefinition(dagster_type=dagster.Any)])
def emit_tasks_for_list(context, a_list: typing.List[typing.Any]):
for num, item in enumerate(a_list):
yield DynamicOutput(item, mapping_key=f'subtask_{num}')
it results in a weird grpc error, recently I've made the list general "[Any]", beforehand it was working with "[str]" any ideas:alex
09/16/2021, 3:21 PM