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 {
151151 . serial_consistency
152152 . unwrap_or ( execution_profile. serial_consistency ) ;
153153
154+ let routing_info = RoutingInfo {
155+ consistency,
156+ serial_consistency,
157+ ..Default :: default ( )
158+ } ;
159+
154160 let retry_session = query
155161 . get_retry_policy ( )
156162 . map ( |rp| & * * rp)
@@ -188,7 +194,7 @@ impl RowIterator {
188194 sender : sender. into ( ) ,
189195 choose_connection,
190196 page_query,
191- statement_info : RoutingInfo :: default ( ) ,
197+ statement_info : routing_info ,
192198 query_is_idempotent : query. config . is_idempotent ,
193199 query_consistency : consistency,
194200 retry_session,
@@ -237,7 +243,7 @@ impl RowIterator {
237243 let worker_task = async move {
238244 let statement_info = RoutingInfo {
239245 consistency,
240- serial_consistency : config . prepared . get_serial_consistency ( ) ,
246+ serial_consistency,
241247 token : config. token ,
242248 keyspace : config. prepared . get_keyspace_name ( ) ,
243249 is_confirmed_lwt : config. prepared . is_confirmed_lwt ( ) ,
You can’t perform that action at this time.
0 commit comments