[wf-Diagnostics] fix the usage logs data emitted by wf diagnostics

sankari165 · Jan 15, 2025 · 4ae98b8 · 4ae98b8
1 parent be54846
commit 4ae98b8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/service/worker/diagnostics/analytics/emitter.go b/service/worker/diagnostics/analytics/emitter.go
@@ -58,8 +58,8 @@ func (et *emitter) EmitUsageData(ctx context.Context, data WfDiagnosticsUsageDat
 	msg[DiagnosticsWfID] = data.DiagnosticsWorkflowID
 	msg[DiagnosticsWfRunID] = data.DiagnosticsRunID
 	msg[Environment] = data.Environment
-	msg[DiagnosticsStartTime] = data.DiagnosticsStartTime
-	msg[DiagnosticsEndTime] = data.DiagnosticsEndTime
+	msg[DiagnosticsStartTime] = data.DiagnosticsStartTime.UTC().UnixMilli()
+	msg[DiagnosticsEndTime] = data.DiagnosticsEndTime.UTC().UnixMilli()
 
 	serializedMsg, err := json.Marshal(msg)
 	if err != nil {