fix typo in 'sinks/influxdb/logs.rs'

Author: pront

src/sinks/influxdb/logs.rs

@@ -281,11 +281,8 @@ impl HttpEventEncoder<BytesMut> for InfluxDbLogsEncoder {
 
         if let Some(source_type_path) = log.source_type_path() {
             self.tags.replace(source_type_path);
-        }
-
-        if let Some(source_type_key) = log_schema().source_type_key() {
             log.rename_key(
-                (PathPrefix::Event, source_type_key),
+                (PathPrefix::Event, source_type_path),
                 (PathPrefix::Event, &self.source_type_key),
             );
         }

src/sources/http_server.rs

@@ -964,7 +964,9 @@ mod tests {
                 lookup::PathPrefix::Event,
                 log_schema().source_type_key().unwrap(),
             ))
-            .unwrap().as_str().unwrap();
+            .unwrap()
+            .as_str()
+            .unwrap();
         assert_eq!(source_type_key_value, SimpleHttpConfig::NAME);
         assert_eq!(log["http_path"], "/".into());
     }