@@ -139,11 +139,11 @@ impl<'cluster> Driver<'cluster> {
139
139
for ( node_id, state, events) in self . runner . pending_events ( ) {
140
140
for ( _, event) in events {
141
141
if f ( node_id, event, state) {
142
- eprintln ! ( "!!! {node_id}: {event:?}" ) ;
142
+ println ! ( "!!! {node_id}: {event:?}" ) ;
143
143
found = Some ( ( node_id, event. clone ( ) ) ) ;
144
144
break ;
145
145
} else {
146
- eprintln ! ( ">>> {node_id}: {event:?}" ) ;
146
+ println ! ( ">>> {node_id}: {event:?}" ) ;
147
147
let event = event. to_string ( ) ;
148
148
steps. push ( ScenarioStep :: Event { node_id, event } ) ;
149
149
}
@@ -177,10 +177,10 @@ impl<'cluster> Driver<'cluster> {
177
177
event : event. to_string ( ) ,
178
178
} ) ;
179
179
if found {
180
- eprintln ! ( "!!! {node_id}: {event:?}" ) ;
180
+ println ! ( "!!! {node_id}: {event:?}" ) ;
181
181
break ' pending_events;
182
182
} else {
183
- eprintln ! ( ">>> {node_id}: {event:?}" ) ;
183
+ println ! ( ">>> {node_id}: {event:?}" ) ;
184
184
}
185
185
}
186
186
}
@@ -207,7 +207,7 @@ impl<'cluster> Driver<'cluster> {
207
207
self . sleep ( duration) . await ;
208
208
self . runner
209
209
. exec_step ( ScenarioStep :: AdvanceTime {
210
- by_nanos : 10 * 1_000_000 ,
210
+ by_nanos : duration . as_nanos ( ) . try_into ( ) ? ,
211
211
} )
212
212
. await ?;
213
213
let nodes = self
0 commit comments