Skip to content
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 TestBuiltinEventTimeExtractor #885

Merged
merged 3 commits into from
Jul 20, 2023
Merged

fix TestBuiltinEventTimeExtractor #885

merged 3 commits into from
Jul 20, 2023

Conversation

yhl25
Copy link
Contributor

@yhl25 yhl25 commented Jul 20, 2023

No description provided.

@yhl25 yhl25 requested a review from KeranYang July 20, 2023 06:19
@@ -272,14 +278,15 @@ wmLoop:
if err != nil {
assert.Fail(s.T(), err.Error())
}
println(edgeWM)
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
println(edgeWM)

// Watermark propagation can delay, we consider the test as passed as long as the retrieved watermark matches one of the assigned event times.
assert.True(s.T(), edgeWM == time.Date(2021, 5, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli() || edgeWM == time.Date(2021, 4, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli() || edgeWM == time.Date(2021, 3, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli() || edgeWM == time.Date(2021, 2, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli() || edgeWM == time.Date(2021, 1, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli())
assert.True(s.T(), edgeWM >= time.Date(2021, 1, 18, 21, 54, 42, 123000000, time.UTC).UnixMilli())
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: would be better if we also have a <= check to ensure that the edgeWM was extracted from msg payload. Without <= check, it could be any timestamp including now.

@yhl25 yhl25 merged commit 85ee4b0 into main Jul 20, 2023
14 checks passed
@yhl25 yhl25 deleted the fx-test branch July 20, 2023 16:55
yhl25 added a commit to yhl25/numaflow that referenced this pull request Aug 1, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants