-
Notifications
You must be signed in to change notification settings - Fork 3.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
fix: Support memoization on plugin node. Fixes #8553 #8554
Conversation
Signed-off-by: wujayway <[email protected]>
Signed-off-by: wujayway <[email protected]>
Signed-off-by: wujayway <[email protected]>
@@ -134,6 +137,13 @@ func (woc *wfOperationCtx) reconcileTaskSet(ctx context.Context) error { | |||
node.FinishedAt = metav1.Now() | |||
|
|||
woc.wf.Status.Nodes[nodeID] = node | |||
if node.MemoizationStatus != nil && node.Succeeded() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
test?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
test?
done
Signed-off-by: wujayway <[email protected]>
Signed-off-by: wujayway <[email protected]>
|
||
func TestReconcileTaskSetWithMemoization(t *testing.T) { | ||
wf := wfv1.MustUnmarshalWorkflow(`apiVersion: argoproj.io/v1alpha1 | ||
kind: Workflow |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This example's length makes it too hard to understand what is the example is relevant to the test, and what is just copied and pasted. Can you please simplify.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ok
Signed-off-by: wujayway <[email protected]>
Signed-off-by: wujayway <[email protected]>
@@ -829,24 +829,40 @@ func TestWorkflow_SearchArtifacts(t *testing.T) { | |||
queriedArtifactSearchResults := wf.SearchArtifacts(query) | |||
assert.NotNil(t, queriedArtifactSearchResults) | |||
assert.Len(t, queriedArtifactSearchResults, 3) | |||
assert.Equal(t, "artifact-foo", queriedArtifactSearchResults[0].Artifact.Name) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
what is this please?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@rohankmr414 maybe this is the fix?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yeah looks like it
Signed-off-by: wujayway <[email protected]>
Signed-off-by: wujayway [email protected]
Fixes #8553