File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -151,6 +151,12 @@ impl RowIterator {
151
151
. serial_consistency
152
152
. unwrap_or ( execution_profile. serial_consistency ) ;
153
153
154
+ let routing_info = RoutingInfo {
155
+ consistency,
156
+ serial_consistency,
157
+ ..Default :: default ( )
158
+ } ;
159
+
154
160
let retry_session = query
155
161
. get_retry_policy ( )
156
162
. map ( |rp| & * * rp)
@@ -188,7 +194,7 @@ impl RowIterator {
188
194
sender : sender. into ( ) ,
189
195
choose_connection,
190
196
page_query,
191
- statement_info : RoutingInfo :: default ( ) ,
197
+ statement_info : routing_info ,
192
198
query_is_idempotent : query. config . is_idempotent ,
193
199
query_consistency : consistency,
194
200
retry_session,
@@ -237,7 +243,7 @@ impl RowIterator {
237
243
let worker_task = async move {
238
244
let statement_info = RoutingInfo {
239
245
consistency,
240
- serial_consistency : config . prepared . get_serial_consistency ( ) ,
246
+ serial_consistency,
241
247
token : config. token ,
242
248
keyspace : config. prepared . get_keyspace_name ( ) ,
243
249
is_confirmed_lwt : config. prepared . is_confirmed_lwt ( ) ,
You can’t perform that action at this time.
0 commit comments