fixup! added UpsertByIdContext in order to register UpsertByIdTask in…

… JobContextService
crate · May 6, 2015 · f084447 · f084447
1 parent 6209f0b
commit f084447
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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();
             }
         });
     }