File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
crates/extensions/tedge_flows/tests Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ async fn stats_are_dumped_when_no_interval_handlers_registered() {
8686 let config = r#"
8787 input.mqtt.topics = ["te/device/main///m/test"]
8888 steps = [{ script = "passthrough.js" }]
89- output.mqtt.topics = [ "te/device/main///m/output"]
89+ output.mqtt.topic = "te/device/main///m/output"
9090 "# ;
9191 std:: fs:: write ( config_dir. join ( "mqtt_only_flow.toml" ) , config) . expect ( "Failed to write config" ) ;
9292
@@ -151,7 +151,7 @@ async fn stats_dumped_when_interval_handlers_present() {
151151 let config = r#"
152152 input.mqtt.topics = ["te/device/main///m/test"]
153153 steps = [{ script = "interval_script.js", interval = "37s" }]
154- output.mqtt.topics = [ "te/device/main///m/output"]
154+ output.mqtt.topic = "te/device/main///m/output"
155155 "# ;
156156 std:: fs:: write ( config_dir. join ( "interval_flow.toml" ) , config) . expect ( "Failed to write config" ) ;
157157
@@ -211,7 +211,7 @@ async fn stats_not_dumped_before_300_seconds() {
211211 let config = r#"
212212 input.mqtt.topics = ["te/device/main///m/test"]
213213 steps = [{ script = "passthrough.js" }]
214- output.mqtt.topics = [ "te/device/main///m/output"]
214+ output.mqtt.topic = "te/device/main///m/output"
215215 "# ;
216216 std:: fs:: write ( config_dir. join ( "mqtt_only_flow.toml" ) , config) . expect ( "Failed to write config" ) ;
217217
You can’t perform that action at this time.
0 commit comments