convert timestamp

Author: seanlaii

historyserver/pkg/eventserver/eventserver.go

@@ -204,8 +204,13 @@ func transformToEvent(eventMap map[string]any) *types.Event {
 	if v, ok := eventMap["sourceType"].(string); ok {
 		event.SourceType = v
 	}
+	// Convert ISO 8601 timestamp to Unix milliseconds to match Ray Dashboard format
 	if v, ok := eventMap["timestamp"].(string); ok {
-		event.Timestamp = v
+		if t, err := time.Parse(time.RFC3339Nano, v); err == nil {
+			event.Timestamp = fmt.Sprintf("%d", t.UnixMilli())
+		} else {
+			event.Timestamp = v // Keep original if parsing fails
+		}
 	}
 	if v, ok := eventMap["severity"].(string); ok {
 		event.Severity = v

historyserver/pkg/eventserver/eventserver_test.go

@@ -928,3 +928,34 @@ func TestMultipleReprocessingCycles(t *testing.T) {
 		}
 	}
 }
+
+func TestTransformToEventTimestamp(t *testing.T) {
+	// Test that transformToEvent correctly converts timestamp format
+	eventMap := map[string]any{
+		"eventId":    "test-event-id",
+		"eventType":  "TASK_DEFINITION_EVENT",
+		"sourceType": "CORE_WORKER",
+		"timestamp":  "2026-01-16T19:22:49.414579427Z",
+		"severity":   "INFO",
+		"taskDefinitionEvent": map[string]any{
+			"taskId": "task-123",
+			"jobId":  "AQAAAA==",
+		},
+	}
+
+	event := transformToEvent(eventMap)
+
+	// Verify timestamp is converted to Unix milliseconds
+	expectedTimestamp := "1768591369414"
+	if event.Timestamp != expectedTimestamp {
+		t.Errorf("transformToEvent timestamp = %q, want %q", event.Timestamp, expectedTimestamp)
+	}
+
+	// Verify other fields are preserved
+	if event.EventID != "test-event-id" {
+		t.Errorf("EventID = %q, want %q", event.EventID, "test-event-id")
+	}
+	if event.SourceType != "CORE_WORKER" {
+		t.Errorf("SourceType = %q, want %q", event.SourceType, "CORE_WORKER")
+	}
+}