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

Enable a couple of retry asserts in internal row to cudf row iterator suite #9251

Merged
merged 2 commits into from
Sep 18, 2023

Conversation

abellina
Copy link
Collaborator

Closes #9168

This is a follow on from #9169. It turns out the asserts work fine if only I had passed the right argument, taskId, instead of threadId. Human error.

… suite

Signed-off-by: Alessandro Bellina <abellina@nvidia.com>
@abellina abellina added the test Only impacts tests label Sep 18, 2023
@abellina
Copy link
Collaborator Author

build

@@ -85,16 +85,13 @@ class GeneratedInternalRowToCudfRowIteratorRetrySuite
ctriter, schema, TargetSize(Int.MaxValue),
NoopMetric, NoopMetric, NoopMetric, NoopMetric, NoopMetric))
RmmSpark.forceRetryOOM(RmmSpark.getCurrentThreadId, 2)
assertResult(0)(RmmSpark.getAndResetNumRetryThrow(RmmSpark.getCurrentThreadId))
assertResult(0)(RmmSpark.getAndResetNumRetryThrow(1))
Copy link
Collaborator

Choose a reason for hiding this comment

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

I don't understand why we are using a thread ID of 1? Could you at least add some comments explaining what is happening here?

Copy link
Collaborator Author

@abellina abellina Sep 18, 2023

Choose a reason for hiding this comment

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

That's actually taskId, and that was my confusion. I'll add a comment. This task id is what we told RmmSpark we wanted to associate RmmSpark.getCurrentThreadId to in the RmmSparkRetrySuiteBase.beforeEach method.

Copy link
Collaborator

Choose a reason for hiding this comment

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

That's right I forgot my own APIs.

@abellina
Copy link
Collaborator Author

build

@abellina abellina merged commit 0f8dc74 into NVIDIA:branch-23.10 Sep 18, 2023
@abellina abellina deleted the enable_retry_asserts_in_test branch September 18, 2023 20:55
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
test Only impacts tests
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[BUG] Calling RmmSpark.getAndResetNumRetryThrow from tests is not working
2 participants