Lewis Bails10/20/2020, 7:29 AM
It first came about after I included a switch statement that chooses between a mapped task, or a normal task that returns an iterable. For example:
Failed: At least one upstream state has an unmappable result.
Is this a valid use of "results" in the downstream task? Is it possible this is where my error is coming from?
with case(use_map, True): results = some_task.map(inputs) # some_task returns mapped results with case(use_map, False): results = manual_mapping_task(inputs) # manual_mapping_task returns python iterable in its results downstream_task(results) # "Failed: At least one upstream state has an unmappable result"
Jim Crist-Harif10/20/2020, 1:46 PM
Lewis Bails10/21/2020, 8:48 AM