[BUG] ArrayNode maptask subnode/task eventing

[pvditt]

Describe the bug

Map task succeeds with respect to min_success_ratio but the last running tasks fail. The last running tasks should get set to phase failed but are stuck in running according to console. This is just an eventing issue.

Expected behavior

Parent task succeeds + subtask has phase failed

Additional context to reproduce

@task( retries=0, ) def hello(name: str) -> None: if name == "b": time.sleep(10) raise "b is not allowed" return

@workflow def map_workflow(): map_task(hello, min_success_ratio=0.5, concurrency=0)(name=["a", "b", "c"])

Screenshots

No response

Are you sure this issue hasn't been raised already?

• [X] Yes

Have you read the Code of Conduct?

• [X] Yes