feat: add last_sdk_version to workflow activation (#1040)

Author: chris-olszewski

core/src/internal_flags.rs

@@ -203,6 +203,15 @@ impl InternalFlags {
             Self::Disabled => Either::Right(iter::empty()),
         }
     }
+
+    pub(crate) fn last_sdk_version(&self) -> Option<&str> {
+        match self {
+            InternalFlags::Enabled {
+                last_sdk_version, ..
+            } if !last_sdk_version.is_empty() => Some(last_sdk_version),
+            InternalFlags::Enabled { .. } | InternalFlags::Disabled => None,
+        }
+    }
 }
 
 impl CoreInternalFlags {

core/src/worker/workflow/machines/workflow_machines.rs

@@ -463,6 +463,11 @@ impl WorkflowMachines {
             continue_as_new_suggested: self.continue_as_new_suggested,
             deployment_version_for_current_task: deployment_version_for_current_task
                 .map(Into::into),
+            last_sdk_version: (*self.observed_internal_flags)
+                .borrow()
+                .last_sdk_version()
+                .unwrap_or_default()
+                .to_owned(),
         }
     }
 

sdk-core-protos/protos/local/temporal/sdk/core/workflow_activation/workflow_activation.proto

@@ -92,6 +92,8 @@ message WorkflowActivation {
     // build id, if this worker was using the deprecated Build ID-only
     // feature(s).
     common.WorkerDeploymentVersion deployment_version_for_current_task = 9;
+    // The last seen SDK version from the most recent WFT completed event
+    string last_sdk_version = 10;
 }
 
 message WorkflowActivationJob {

sdk-core-protos/src/lib.rs

@@ -519,6 +519,7 @@ pub mod coresdk {
                 history_size_bytes: 0,
                 continue_as_new_suggested: false,
                 deployment_version_for_current_task: None,
+                last_sdk_version: String::new(),
             }
         }