Skip to content

Commit

Permalink
Check if iterationIndex is nil
Browse files Browse the repository at this point in the history
Signed-off-by: droctothorpe <[email protected]>
Co-authored-by: zazulam <[email protected]>
  • Loading branch information
droctothorpe and zazulam committed Oct 22, 2024
1 parent 0076a2d commit 7f17895
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions backend/src/v2/driver/driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -1245,8 +1245,11 @@ func getDAGTasks(
// within a single DAG, which results in an error when
// mlmd.GetExecutionsInDAG is called. ParallelFor outputs should be
// handled with dsl.Collected.
if _, ok := v.GetExecution().GetCustomProperties()["iteration_index"]; !ok {
continue
if iterationIndex, ok := v.GetExecution().GetCustomProperties()["iteration_index"]; !ok {
// First we check if the key exists, then we check if it's not nil.
if !(iterationIndex == nil) {
continue
}
}
glog.V(4).Infof("Found a task, %v, with an execution type of system.DAGExecution. Adding its tasks to the task list.", v.TaskName())
subDAG, err := mlmd.GetDAG(ctx, v.GetExecution().GetId())
Expand Down

0 comments on commit 7f17895

Please sign in to comment.