Skip to content

Commit

Permalink
added comment to remember how to address dynamic hera workflow api ca…
Browse files Browse the repository at this point in the history
…ll responses
  • Loading branch information
SebastianScherer88 committed Aug 12, 2024
1 parent 558e277 commit 960465c
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions sdk/bettmensch_ai/server/flow.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,12 @@ def build_dag(cls, workflow_status: Dict) -> List[FlowNode]:
== pipeline_node_dict["name"]
][0]
)
# if the above gives an index error, its because the workflow node
# hasnt been scheduled and is not in pending state yet, meaning the
# hera api workflow response does not include it. in that case we
# need to assemble the flow node dict from its pipeline equivalent
# where possible and sensible and set the state to "Not scheduled
# yet" or similar

flow_node_dict = {
"id": workflow_node_dict["id"],
Expand Down

0 comments on commit 960465c

Please sign in to comment.