Lewis Bails
10/20/2020, 7:29 AMFailed: At least one upstream state has an unmappable result.
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:
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"
Is this a valid use of "results" in the downstream task? Is it possible this is where my error is coming from?Jim Crist-Harif
10/20/2020, 1:46 PMLewis Bails
10/21/2020, 8:48 AM