We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f367787 commit 815301bCopy full SHA for 815301b
1 file changed
src/test/java/io/weaviate/client6/v1/api/collections/batch/BatchContextTest.java
@@ -162,6 +162,7 @@ private void closeContext() throws Exception {
162
} catch (Exception e) {
163
throw new RuntimeException(e);
164
}
165
+ log.debug("SENDING EOF ON {}");
166
}, backgroundThread).thenCompose(__ -> out.eof(true));
167
168
try {
@@ -187,6 +188,7 @@ public void test_sendOneBatch() throws Exception {
187
188
Assertions.assertThat(tasks)
189
.extracting(TaskHandle::isAcked).allMatch(CompletableFuture::isDone);
190
191
+ log.debug("ADD PENDING TO {}", out);
192
out.pendingEvents.add(new Event.Results(received, Collections.emptyMap()));
193
out.beforeEof(new Event.Results(received, Collections.emptyMap()));
194
0 commit comments