diff --git a/sql/src/main/java/io/crate/jobs/UpsertByIdContext.java b/sql/src/main/java/io/crate/jobs/UpsertByIdContext.java
index b0e952bb1f2d..99554f6daf85 100644
--- a/sql/src/main/java/io/crate/jobs/UpsertByIdContext.java
+++ b/sql/src/main/java/io/crate/jobs/UpsertByIdContext.java
@@ -77,6 +77,7 @@ public void onResponse(ShardUpsertResponse updateResponse) {
                     }
                     futureResult.set(TaskResult.ZERO);
                 }
+                close();
             }
 
             @Override
@@ -90,6 +91,7 @@ public void onFailure(Throwable e) {
                 } else {
                     futureResult.setException(e);
                 }
+                close();
             }
         });
     }