Rebase change

Author: slinkydeveloper

crates/types/src/invocation/mod.rs

@@ -978,7 +978,6 @@ pub struct PurgeInvocationRequest {
     pub response_sink: Option<InvocationMutationResponseSink>,
     /// When epoch is the current/latest epoch, all the other epochs will be cleaned up as well.
     #[serde(default, skip_serializing_if = "num_traits::Zero::is_zero")]
-    #[bilrost(6)]
     pub invocation_epoch: InvocationEpoch,
 }
 
@@ -1165,12 +1164,14 @@ pub mod restart {
         ///
         /// To retain the previous attempt, the new attempt will take the invocation id of the previous attempt, the one used to trigger this reset,
         /// and old invocation id will take a new randomly generated invocation id.
+        #[serde(default, skip_serializing_if = "Option::is_none")]
         pub previous_attempt_retention: Option<Duration>,
 
         /// What to do in case the invocation was a Workflow run (workflow service and workflow handler type)
         pub apply_to_workflow_run: ApplyToWorkflowRun,
 
         /// Where to send the response for this command
+        #[serde(default, skip_serializing_if = "Option::is_none")]
         pub response_sink: Option<InvocationMutationResponseSink>,
     }
 

crates/worker/src/partition/state_machine/lifecycle/restart.rs

@@ -297,11 +297,12 @@ where
             completion_range_epoch_map: invocation.completion_range_epoch_map,
             journal_metadata: invocation.journal_metadata,
             hotfix_apply_cancellation_after_deployment_is_pinned: false,
+            created_using_restate_version: invocation.created_using_restate_version,
 
             // Reset the pinned deployment
             pinned_deployment: None,
             // Reset timestamps
-            timestamps: StatusTimestamps::now(),
+            timestamps: StatusTimestamps::init(),
             // Reset response sinks
             response_sinks: Default::default(),
         };