Hi Team, we are using flyte 1.10.2 in our organization and we are running workflows pretty much smoothly. However we wanted to explore map_task along with python notebook to spin up notebook parallel associate with parallel task, while testing basic map_task functionality all we are getting is this below error. Other workflows are working fine this is appearing only for map_task related workflows.
Last error: UNKNOWN::Outputs not generated by task execution (edited)
We also tried the experimental.map_task also, but the issue remained same.
from typing import List
from flytekit import map_task, task, workflow
@task
def a_mappable_task(a: int) -> str:
inc = a + 2
print(inc)
return str(inc)
@workflow
def my_map_workflow(a: List[int]) -> List[str]:
mapped_out = map_task(a_mappable_task)(a=a)
return mapped_out
if __name__ == "__main__":
result = my_map_workflow(a=[2,3,4,5])
print(f"{result}")
this is the simple code snippet, we are using to test. When we look into logs we are only able to see the first iterated item. In this case, its 2 and in log the print shows 4 as its incremented and next whole workflow fails with the above error.
Could someone please assist us in determining what we may have overlooked in configuration that is creating this issue?
