Skip to content

Force dataset refresh before reads during polling #201

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.

Sign up for GitHub

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

Merged
psainics merged 1 commit into from
Feb 2, 2026

Force dataset refresh before reads during polling and after stopping …

f9ede52
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

Force dataset refresh before reads during polling #201

Force dataset refresh before reads during polling and after stopping …
f9ede52
Select commit
Loading
Failed to load commit list.
GitHub Actions / Build Test Report failed Feb 2, 2026 in 0s

87 tests run, 86 passed, 0 skipped, 1 failed.

Annotations

Check failure on line 118 in HttpStreamingSourceETLTest

See this annotation in the file changed.

@github-actions github-actions / Build Test Report

HttpStreamingSourceETLTest.testIncrementAnIndexXml 

Assertion condition defined as a lambda expression in io.cdap.plugin.http.etl.HttpStreamingSourceETLTest that uses io.cdap.cdap.test.DataSetManager, io.cdap.cdap.test.DataSetManagerint At least 25 records expected, but 20 found within 120 seconds.
Raw output 
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a lambda expression in io.cdap.plugin.http.etl.HttpStreamingSourceETLTest that uses io.cdap.cdap.test.DataSetManager, io.cdap.cdap.test.DataSetManagerint At least 25 records expected, but 20 found within 120 seconds.
	at org.junit.Assert.fail(Assert.java:88)
	at org.junit.Assert.assertTrue(Assert.java:41)
	at io.cdap.plugin.http.etl.HttpStreamingSourceETLTest.lambda$waitForRecords$0(HttpStreamingSourceETLTest.java:118)
View more details on GitHub Actions