diff --git a/nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiInsertManyOpDispenser.java b/nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiInsertManyOpDispenser.java index 10788cfea..d51789523 100644 --- a/nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiInsertManyOpDispenser.java +++ b/nb-adapters/adapter-dataapi/src/main/java/io/nosqlbench/adapter/dataapi/opdispensers/DataApiInsertManyOpDispenser.java @@ -66,6 +66,8 @@ public class DataApiInsertManyOpDispenser extends DataApiOpDispenser { options = options.concurrency(Integer.parseInt(entry.getValue())); case "ordered" -> options = options.ordered(Boolean.parseBoolean(entry.getValue())); + case "timeout" -> + options = options.timeout(Integer.parseInt(entry.getValue())); } } }