Skip to content
This repository was archived by the owner on May 8, 2026. It is now read-only.
Original file line number Diff line number Diff line change
Expand Up @@ -281,7 +281,7 @@ public ApiFuture<Pipeline.Snapshot> execute(
@Nonnull Pipeline pipeline, @Nonnull PipelineExecuteOptions options) {
Preconditions.checkState(isEmpty(), READ_BEFORE_WRITE_ERROR_MSG);
try (TraceUtil.Scope ignored = transactionTraceContext.makeCurrent()) {
return pipeline.execute(new PipelineExecuteOptions(), transactionId, null);
return pipeline.execute(options, transactionId, null);
}
}
}
Loading