F

Flyte enables you to build & deploy data & ML pipelines, hassle-free. The infinitely scalable and flexible workflow orchestration platform that seamlessly unifies data, ML and analytics stacks. Explore and Join the Flyte Community!

TypeError with dynamic tasks in Python

Summary

The user is experiencing a TypeError when trying to combine map tasks, dynamic tasks, and the min_success_ratio parameter in Python, which indicates an issue with converting task outputs from a list to a typing.Optional[float]. They can run the workflow in a cluster using pyflyte run, but encounter an AttributeError related to a 'NoneType' object lacking a 'project' attribute in a dynamic task. The user is surprised by these issues, as the relevant line in the translator hasn't changed for years, and they are questioning whether dynamic tasks are expected to work within map tasks.

Status
resolved
Tags
    Source
    #ask-the-community