@@ -237,13 +237,14 @@ public void actual_run() {
237237 if (this .sdk != null )
238238 result = docops .bulkInsert (this .sdk .connection , docs , setOptions );
239239 ops += dg .ws .batchSize *dg .ws .creates /100 ;
240- if (this .trackFailures && result .size ()>0 )
240+ if (this .trackFailures && result .size ()>0 ){
241241 this .result = false ;
242242 try {
243243 failedMutations .get ("create" ).addAll (result );
244244 } catch (Exception e ) {
245245 failedMutations .put ("create" , result );
246246 }
247+ }
247248 }
248249 }
249250 if (dg .ws .updates > 0 ) {
@@ -257,13 +258,14 @@ public void actual_run() {
257258 if (this .sdk != null )
258259 result = docops .bulkUpsert (this .sdk .connection , docs , upsertOptions );
259260 ops += dg .ws .batchSize *dg .ws .updates /100 ;
260- if (this .trackFailures && result .size ()>0 )
261+ if (this .trackFailures && result .size ()>0 ){
261262 this .result = false ;
262263 try {
263264 failedMutations .get ("update" ).addAll (result );
264265 } catch (Exception e ) {
265266 failedMutations .put ("update" , result );
266267 }
268+ }
267269 }
268270 }
269271 if (dg .ws .expiry > 0 ) {
@@ -274,13 +276,14 @@ public void actual_run() {
274276 if (this .sdk != null )
275277 result = docops .bulkInsert (this .sdk .connection , docs , expiryOptions );
276278 ops += dg .ws .batchSize *dg .ws .expiry /100 ;
277- if (this .trackFailures && result .size ()>0 )
279+ if (this .trackFailures && result .size ()>0 ){
278280 this .result = false ;
279281 try {
280282 failedMutations .get ("expiry" ).addAll (result );
281283 } catch (Exception e ) {
282284 failedMutations .put ("expiry" , result );
283285 }
286+ }
284287 }
285288 }
286289 if (dg .ws .deletes > 0 ) {
@@ -294,13 +297,14 @@ public void actual_run() {
294297 this .esClient .deleteDocs (this .collection .replace ("_" , "" ), docs );
295298 }
296299 ops += dg .ws .batchSize *dg .ws .deletes /100 ;
297- if (this .trackFailures && result .size ()>0 )
300+ if (this .trackFailures && result .size ()>0 ){
298301 this .result = false ;
299302 try {
300303 failedMutations .get ("delete" ).addAll (result );
301304 } catch (Exception e ) {
302305 failedMutations .put ("delete" , result );
303306 }
307+ }
304308 }
305309 }
306310 if (dg .ws .reads > 0 ) {
0 commit comments