logging

temporalio · Dec 5, 2023 · 20b7bac · 20b7bac
1 parent 78fbc69
commit 20b7bac
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/core/src/worker/workflow/machines/workflow_machines.rs b/core/src/worker/workflow/machines/workflow_machines.rs
@@ -15,6 +15,7 @@ use super::{
 use crate::{
     abstractions::dbg_panic,
     internal_flags::InternalFlags,
+    log_to_file::log_to_file,
     protosext::{
         protocol_messages::{IncomingProtocolMessage, IncomingProtocolMessageBody},
         CompleteLocalActivityData, HistoryEventExt, ValidScheduleLA,
@@ -1447,6 +1448,11 @@ impl WorkflowMachines {
     }
 
     fn get_machine_by_msg(&self, protocol_instance_id: &str) -> Result<MachineKey> {
+        log_to_file(
+            &format!("protocol_instance_id: {protocol_instance_id}"),
+            "sdk-core:get_machine_by_msg",
+            "blue",
+        );
         Ok(*self
             .machines_by_protocol_instance_id
             .get(protocol_instance_id)
@@ -1490,6 +1496,11 @@ impl WorkflowMachines {
     }
 
     fn add_new_protocol_machine(&mut self, machine: Machines, instance_id: String) -> MachineKey {
+        log_to_file(
+            &format!("protocol_instance_id: {instance_id}"),
+            "add_new_protocol_machine",
+            "blue",
+        );
         let k = self.all_machines.insert(machine);
         self.machines_by_protocol_instance_id.insert(instance_id, k);
         k