From 25f61d9245e47e14203e1f1aa0062ee48bd7e674 Mon Sep 17 00:00:00 2001
From: Evis Drenova <80707987+evisdrenova@users.noreply.github.com>
Date: Mon, 9 Dec 2024 16:15:06 -0800
Subject: [PATCH] NEOS-1662: update GetJobRunEvents to properly parse metadata
 (#3029)

---
 .../mgmt/v1alpha1/job-service/runs.go         | 25 ++++++++++++-------
 1 file changed, 16 insertions(+), 9 deletions(-)

diff --git a/backend/services/mgmt/v1alpha1/job-service/runs.go b/backend/services/mgmt/v1alpha1/job-service/runs.go
index aae6cb11ad..40460b200e 100644
--- a/backend/services/mgmt/v1alpha1/job-service/runs.go
+++ b/backend/services/mgmt/v1alpha1/job-service/runs.go
@@ -145,19 +145,27 @@ func (s *Service) GetJobRunEvents(
 				},
 			}
 			if len(attributes.Input.Payloads) > 1 {
-				var input mgmtv1alpha1.JobRunSyncMetadata
-				err := converter.GetDefaultDataConverter().FromPayload(attributes.Input.Payloads[1], &input)
+				var rawMap map[string]string
+				err := converter.GetDefaultDataConverter().FromPayload(attributes.Input.Payloads[1], &rawMap)
 				if err != nil {
-					logger.Error(fmt.Errorf("unable to convert event input payload: %w", err).Error())
+					logger.Error(fmt.Errorf("unable to convert to event input payload: %w", err).Error())
 				}
-				jobRunEvent.Metadata = &mgmtv1alpha1.JobRunEventMetadata{
-					Metadata: &mgmtv1alpha1.JobRunEventMetadata_SyncMetadata{
+
+				schema, schemaExists := rawMap["Schema"]
+				table, tableExists := rawMap["Table"]
+
+				metadata := &mgmtv1alpha1.JobRunEventMetadata{}
+
+				if schemaExists && tableExists {
+					metadata.Metadata = &mgmtv1alpha1.JobRunEventMetadata_SyncMetadata{
 						SyncMetadata: &mgmtv1alpha1.JobRunSyncMetadata{
-							Schema: input.Schema,
-							Table:  input.Table,
+							Schema: schema,
+							Table:  table,
 						},
-					},
+					}
 				}
+
+				jobRunEvent.Metadata = metadata
 			}
 			activityMap[event.EventId] = jobRunEvent
 		case enums.EVENT_TYPE_ACTIVITY_TASK_STARTED:
@@ -171,7 +179,6 @@ func (s *Service) GetJobRunEvents(
 			activity := activityMap[attributes.ScheduledEventId]
 			activity.CloseTime = event.EventTime
 			activity.Tasks = append(activity.Tasks, dtomaps.ToJobRunEventTaskDto(event, nil))
-
 		case enums.EVENT_TYPE_ACTIVITY_TASK_CANCEL_REQUESTED:
 			attributes := event.GetActivityTaskCancelRequestedEventAttributes()
 			activity := activityMap[attributes.ScheduledEventId]