Skip to content

Commit 086d004

Browse files
committed
update query timestamp generation
1 parent 9329d84 commit 086d004

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lib/requests.js

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,7 @@ class ExecuteRequest extends Request {
121121
this.params = params;
122122
this.meta = meta;
123123
this.options = execOptions || ExecutionOptions.empty();
124+
this.timestamp = this.options.getOrGenerateTimestamp();
124125
this.consistency = this.options.getConsistency() || types.consistencies.one;
125126
// Only QUERY request parameters are encoded as named parameters
126127
// EXECUTE request parameters are always encoded as positional parameters
@@ -174,7 +175,7 @@ class ExecuteRequest extends Request {
174175
// [<serial_consistency>][<timestamp>][keyspace][continuous_paging_options]
175176
let flags = 0;
176177

177-
const timestamp = this.options.getOrGenerateTimestamp();
178+
const timestamp = this.timestamp;
178179

179180
if (types.protocolVersion.supportsPaging(encoder.protocolVersion)) {
180181
flags |= (this.params && this.params.length) ? queryFlag.values : 0;
@@ -407,6 +408,7 @@ class BatchRequest extends Request {
407408
super();
408409
this.queries = queries;
409410
this.options = execOptions;
411+
this.timestamp = this.options.getOrGenerateTimestamp();
410412
this.hints = execOptions.getHints() || utils.emptyArray;
411413
this.type = batchType.logged;
412414

@@ -463,7 +465,7 @@ class BatchRequest extends Request {
463465
if (types.protocolVersion.supportsTimestamp(encoder.protocolVersion)) {
464466
// Batch flags
465467
let flags = this.options.getSerialConsistency() ? batchFlag.withSerialConsistency : 0;
466-
const timestamp = this.options.getOrGenerateTimestamp();
468+
const timestamp = this.timestamp;
467469
flags |= timestamp !== null && timestamp !== undefined ? batchFlag.withDefaultTimestamp : 0;
468470

469471
flags |= this.options.getKeyspace() && types.protocolVersion.supportsKeyspaceInRequest(encoder.protocolVersion)

0 commit comments

Comments
 (0)