Add function to inject_logs

Author: gefjon

crates/core/src/host/module_host.rs

@@ -1021,7 +1021,7 @@ impl ModuleHost {
             _ => None,
         };
         if let Some(log_message) = log_message {
-            self.inject_logs(LogLevel::Error, &log_message)
+            self.inject_logs(LogLevel::Error, reducer_name, &log_message)
         }
 
         res
@@ -1110,10 +1110,15 @@ impl ModuleHost {
         tokio::join!(self.module.scheduler().closed(), self.job_tx.closed());
     }
 
-    pub fn inject_logs(&self, log_level: LogLevel, message: &str) {
-        self.replica_ctx()
-            .logger
-            .write(log_level, &Record::injected(message), &())
+    pub fn inject_logs(&self, log_level: LogLevel, reducer_name: &str, message: &str) {
+        self.replica_ctx().logger.write(
+            log_level,
+            &Record {
+                function: Some(reducer_name),
+                ..Record::injected(message)
+            },
+            &(),
+        )
     }
 
     /// Execute a one-off query and send the results to the given client.