Merge 4fdd54b into 47b254b

spotify · Nov 9, 2023 · fc5dd11 · fc5dd11
2 parents 47b254b + 4fdd54b
commit fc5dd11
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncBatchLookupDoFn.java b/scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncBatchLookupDoFn.java
@@ -197,8 +197,9 @@ public void finishBundle(FinishBundleContext context) {
 
     // send remaining
     try {
-      /** @todo handle exception properly * */
-      createRequest();
+      if (!batch.isEmpty()) {
+        createRequest();
+      }
       if (!futures.isEmpty()) {
         // Block until all pending futures are complete
         waitForFutures(futures.values());