Commit 22cb141d authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Try to wait for stuff to be initialized.

parent 03dfa568
Pipeline #33594 canceled with stages
in 21 minutes and 54 seconds
......@@ -85,6 +85,12 @@ class TestPipeline {
@Test
fun `test 1 minimal configuration`() {
val topics = setupTest(1, "test-1")
while (topics.first.isEmpty) {
}
assertThat(topics.second.isEmpty)
.withFailMessage("Reports topic is empty.")
.isFalse()
val record = topics.first.readRecord()
val recordValue = record.value
......@@ -106,6 +112,12 @@ class TestPipeline {
@Test
fun `test 2 minimal configuration with digital and physical object`() {
val topics = setupTest(2, "test-2")
while (topics.first.isEmpty) {
}
assertThat(topics.second.isEmpty)
.withFailMessage("Reports topic is empty.")
.isFalse()
val record = topics.first.readRecord()
val recordValue = record.value
......@@ -127,7 +139,9 @@ class TestPipeline {
@Test
fun `test 3 test list input`() {
val topics = setupTest(3, "test-3")
while (topics.first.isEmpty) {
}
assertThat(topics.second.isEmpty)
.withFailMessage("Reports topic is empty.")
.isFalse()
......@@ -172,6 +186,13 @@ class TestPipeline {
fun `test 4 if proxy field in mapping works`() {
val topics = setupTest(4, "test-4")
while (topics.first.isEmpty) {
}
assertThat(topics.second.isEmpty)
.withFailMessage("Reports topic is empty.")
.isFalse()
val report = topics.second.readRecord()
val reportKey = report.key
val reportValue = report.value
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment