https://dagster.io/ logo
Title
s

Sebastian Napiorkowski

09/15/2021, 3:42 PM
I'm creating DynamicOutputs like this:
@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:
a

alex

09/16/2021, 3:21 PM
sorry this got missed yesterday - following up here https://dagster.slack.com/archives/C01U954MEER/p1631795632029500