https://flyte.org
Join Slack
Hi team, Can we set timeouts only for a sub-workflow which is defined under dynamic task? ```ground...
# flyte-support
s
Hi team, Can we set timeouts only for a sub-workflow which is defined under dynamic task?
Copy code
ground_truth_workflow = flytekit.LaunchPlan.get_or_create(
    name="ground_truth_workflow",
    workflow=GroundTruthOfflinePCPWorkFlow,
)
Dynamic tasks calls a launch plan.
Copy code
@flytekit.dynamic
def run:
     # Figures out number of iterations
     ground_truth_workflow(..)
for each iteration of “run” - is it possible to safely set a timeout ?
f
Timeout for the entire workflow?
s
timeout for ground_truth_workflow .. 🙂
t
I don’t think it’s possible but there may be a workaround. Will let @high-accountant-32689 / @thankful-minister-83577 confirm.
f
@sticky-art-97180 / @tall-lock-23197 it’s possible in the backend just not exposed today. Can we a good feature request
I guess I would call It deadline instead of timeout
s
ahh thats great, thank you so much guys! 🙏
f
@sticky-art-97180 actually i am wrong
you can put timeout on the node, i.e. subworkflows
you just have to do it at the node-level when you are using it in the workflow
s
that’s still okay, .. I expect the sub-workflows to finish by ~2 hours. if they take more than that, its a problem with one of my tasks not finishing up and stuck somewhere
154 Views
Open in Slack
PreviousNext
Powered by

Flyte

Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.

Powered by