changed startTime/endTime to startTimeUtc/endTimeUtc and made the request times DateTimeOffset

Author: Sophia Tevosyan

src/Shared/Grpc/ProtoUtils.cs

@@ -617,16 +617,16 @@ internal static void ToEntityBatchRequest(
                 return new OperationResult()
                 {
                     Result = operationResult.Success.Result,
-                    StartTime = operationResult.Success.StartTime?.ToDateTime(),
-                    EndTime = operationResult.Success.EndTime?.ToDateTime(),
+                    StartTimeUtc = operationResult.Success.StartTimeUtc?.ToDateTime(),
+                    EndTimeUtc = operationResult.Success.EndTimeUtc?.ToDateTime(),
                 };
 
             case P.OperationResult.ResultTypeOneofCase.Failure:
                 return new OperationResult()
                 {
                     FailureDetails = operationResult.Failure.FailureDetails.ToCore(),
-                    StartTime = operationResult.Failure.StartTime?.ToDateTime(),
-                    EndTime = operationResult.Failure.EndTime?.ToDateTime(),
+                    StartTimeUtc = operationResult.Failure.StartTimeUtc?.ToDateTime(),
+                    EndTimeUtc = operationResult.Failure.EndTimeUtc?.ToDateTime(),
                 };
 
             default:
@@ -654,8 +654,8 @@ internal static void ToEntityBatchRequest(
                 Success = new P.OperationResultSuccess()
                 {
                     Result = operationResult.Result,
-                    StartTime = operationResult.StartTime?.ToTimestamp(),
-                    EndTime = operationResult.EndTime?.ToTimestamp(),
+                    StartTimeUtc = operationResult.StartTimeUtc?.ToTimestamp(),
+                    EndTimeUtc = operationResult.EndTimeUtc?.ToTimestamp(),
                 },
             };
         }
@@ -666,8 +666,8 @@ internal static void ToEntityBatchRequest(
                 Failure = new P.OperationResultFailure()
                 {
                     FailureDetails = ToProtobuf(operationResult.FailureDetails),
-                    StartTime = operationResult.StartTime?.ToTimestamp(),
-                    EndTime = operationResult.EndTime?.ToTimestamp(),
+                    StartTimeUtc = operationResult.StartTimeUtc?.ToTimestamp(),
+                    EndTimeUtc = operationResult.EndTimeUtc?.ToTimestamp(),
                 },
             };
         }
@@ -696,7 +696,7 @@ internal static void ToEntityBatchRequest(
                     Input = operationAction.SendSignal.Input,
                     InstanceId = operationAction.SendSignal.InstanceId,
                     ScheduledTime = operationAction.SendSignal.ScheduledTime?.ToDateTime(),
-                    RequestTime = operationAction.SendSignal.RequestTime?.ToDateTime(),
+                    RequestTime = operationAction.SendSignal.RequestTime?.ToDateTimeOffset(),
                     ParentTraceContext = operationAction.SendSignal.ParentTraceContext != null ?
                         new DistributedTraceContext(
                             operationAction.SendSignal.ParentTraceContext.TraceParent,
@@ -712,7 +712,7 @@ internal static void ToEntityBatchRequest(
                     InstanceId = operationAction.StartNewOrchestration.InstanceId,
                     Version = operationAction.StartNewOrchestration.Version,
                     ScheduledStartTime = operationAction.StartNewOrchestration.ScheduledTime?.ToDateTime(),
-                    RequestTime = operationAction.StartNewOrchestration.RequestTime?.ToDateTime(),
+                    RequestTime = operationAction.StartNewOrchestration.RequestTime?.ToDateTimeOffset(),
                     ParentTraceContext = operationAction.StartNewOrchestration.ParentTraceContext != null ?
                         new DistributedTraceContext(
                             operationAction.StartNewOrchestration.ParentTraceContext.TraceParent,

src/Worker/Core/Shims/TaskEntityShim.cs

@@ -74,8 +74,8 @@ public override async Task<EntityBatchResult> ExecuteOperationBatchAsync(EntityB
                 results.Add(new OperationResult()
                 {
                     Result = serializedResult,
-                    StartTime = startTime,
-                    EndTime = DateTime.UtcNow,
+                    StartTimeUtc = startTime,
+                    EndTimeUtc = DateTime.UtcNow,
                 });
 
                 // the user code completed without exception, so we commit the current state and actions.
@@ -88,8 +88,8 @@ public override async Task<EntityBatchResult> ExecuteOperationBatchAsync(EntityB
                 results.Add(new OperationResult()
                 {
                     FailureDetails = new FailureDetails(applicationException),
-                    StartTime = startTime,
-                    EndTime = DateTime.UtcNow,
+                    StartTimeUtc = startTime,
+                    EndTimeUtc = DateTime.UtcNow,
                 });
 
                 // the user code threw an unhandled exception, so we roll back the state and the actions.
@@ -232,7 +232,7 @@ public override void SignalEntity(EntityInstanceId id, string operationName, obj
                 Name = operationName,
                 Input = this.dataConverter.Serialize(input),
                 ScheduledTime = options?.SignalTime?.UtcDateTime,
-                RequestTime = DateTime.UtcNow,
+                RequestTime = DateTimeOffset.UtcNow,
                 ParentTraceContext = this.parentTraceContext,
             });
         }
@@ -249,7 +249,7 @@ public override string ScheduleNewOrchestration(TaskName name, object? input = n
                 InstanceId = instanceId,
                 Input = this.dataConverter.Serialize(input),
                 ScheduledStartTime = options?.StartAt?.UtcDateTime,
-                RequestTime = DateTime.UtcNow,
+                RequestTime = DateTimeOffset.UtcNow,
                 ParentTraceContext = this.parentTraceContext,
             });
             return instanceId;