Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
change var name
Browse files Browse the repository at this point in the history
Signed-off-by: Yee Hing Tong <[email protected]>
  • Loading branch information
wild-endeavor committed May 5, 2023
1 parent 19b7443 commit 9f919a2
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/common/flyte_url.go
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,13 @@ func ParseFlyteURL(flyteURL string) (core.NodeExecutionIdentifier, *int, Artifac
domain := matches["domain"]
executionID := matches["exec"]
nodeID := matches["node"]
var attempt *int // nil means node execution, not a task execution
var attemptPtr *int // nil means node execution, not a task execution
if attempt := matches["attempt"]; len(attempt) > 0 {
a, err := strconv.Atoi(attempt)
if err != nil {
return core.NodeExecutionIdentifier{}, nil, ArtifactTypeUndefined, fmt.Errorf("failed to parse attempt [%v], %v", attempt, err)
}
attempt = &a
attemptPtr = &a
}
ioType, err := ArtifactTypeString(matches["artifactType"])
if err != nil {
Expand All @@ -66,7 +66,7 @@ func ParseFlyteURL(flyteURL string) (core.NodeExecutionIdentifier, *int, Artifac
Domain: domain,
Name: executionID,
},
}, attempt, ioType, nil
}, attemptPtr, ioType, nil
}

func FlyteURLsFromNodeExecutionID(nodeExecutionID core.NodeExecutionIdentifier, deck bool) *admin.FlyteURLs {
Expand Down

0 comments on commit 9f919a2

Please sign in to comment.