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 9127cc1
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion backend/src/v2/driver/driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -1245,7 +1245,8 @@ 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 {
iterationIndex, ok := v.GetExecution().GetCustomProperties()["iteration_index"]
if ok && 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())
Expand Down

0 comments on commit 9127cc1

Please sign in to comment.