@@ -723,6 +723,7 @@ mod integration_tests {
723
723
transforms:: test:: create_topology,
724
724
} ;
725
725
use std:: collections:: BTreeMap ;
726
+ use vector_common:: assert_event_data_eq;
726
727
use vrl:: value:: Value ;
727
728
use warp:: Filter ;
728
729
@@ -851,7 +852,7 @@ mod integration_tests {
851
852
tx. send ( log. into ( ) ) . await . unwrap ( ) ;
852
853
853
854
let event = out. recv ( ) . await . unwrap ( ) ;
854
- assert_eq ! ( event. into_log( ) , expected_log) ;
855
+ assert_event_data_eq ! ( event. into_log( ) , expected_log) ;
855
856
856
857
drop ( tx) ;
857
858
topology. stop ( ) . await ;
@@ -952,7 +953,7 @@ mod integration_tests {
952
953
tx. send ( metric. into ( ) ) . await . unwrap ( ) ;
953
954
954
955
let event = out. recv ( ) . await . unwrap ( ) ;
955
- assert_eq ! ( event. into_metric( ) , expected_metric) ;
956
+ assert_event_data_eq ! ( event. into_metric( ) , expected_metric) ;
956
957
957
958
drop ( tx) ;
958
959
topology. stop ( ) . await ;
@@ -997,7 +998,7 @@ mod integration_tests {
997
998
tx. send ( log. into ( ) ) . await . unwrap ( ) ;
998
999
999
1000
let event = out. recv ( ) . await . unwrap ( ) ;
1000
- assert_eq ! ( event. into_log( ) , expected_log) ;
1001
+ assert_event_data_eq ! ( event. into_log( ) , expected_log) ;
1001
1002
1002
1003
drop ( tx) ;
1003
1004
topology. stop ( ) . await ;
@@ -1041,7 +1042,7 @@ mod integration_tests {
1041
1042
tx. send ( metric. into ( ) ) . await . unwrap ( ) ;
1042
1043
1043
1044
let event = out. recv ( ) . await . unwrap ( ) ;
1044
- assert_eq ! ( event. into_metric( ) , expected_metric) ;
1045
+ assert_event_data_eq ! ( event. into_metric( ) , expected_metric) ;
1045
1046
1046
1047
drop ( tx) ;
1047
1048
topology. stop ( ) . await ;
0 commit comments