@@ -207,16 +207,16 @@ impl FlowStoreServiceBase for FlowStoreService {
207207mod tests {
208208 use std:: collections:: HashMap ;
209209
210- use crate :: flow_store:: connection:: FlowStore ;
211210 use crate :: flow_store:: connection:: create_flow_store_connection;
211+ use crate :: flow_store:: connection:: FlowStore ;
212212 use crate :: flow_store:: service:: FlowStoreService ;
213213 use crate :: flow_store:: service:: FlowStoreServiceBase ;
214214 use redis:: { AsyncCommands , JsonAsyncCommands } ;
215215 use serial_test:: serial;
216- use testcontainers:: GenericImage ;
217216 use testcontainers:: core:: IntoContainerPort ;
218217 use testcontainers:: core:: WaitFor ;
219218 use testcontainers:: runners:: AsyncRunner ;
219+ use testcontainers:: GenericImage ;
220220 use tucana:: shared:: FlowSetting ;
221221 use tucana:: shared:: FlowSettingDefinition ;
222222 use tucana:: shared:: Struct ;
@@ -323,7 +323,7 @@ mod tests {
323323 let redis_result: Option <String > = {
324324 let mut redis_cmd = connection. lock( ) . await ;
325325 redis_cmd
326- . json_get( "1::1::abc.code0.tech::GET" , "$" )
326+ . json_get( "1::1::REST:: abc.code0.tech::GET" , "$" )
327327 . await
328328 . unwrap( )
329329 } ;
@@ -391,7 +391,7 @@ mod tests {
391391 let redis_result: Vec <String > = {
392392 let mut redis_cmd = connection. lock( ) . await ;
393393 redis_cmd
394- . json_get( "1::1::abc.code0.tech::GET" , "$" )
394+ . json_get( "1::1::REST:: abc.code0.tech::GET" , "$" )
395395 . await
396396 . unwrap( )
397397 } ;
0 commit comments