[core] Publish ODC partition state changes

AliceO2Group · Mar 21, 2024 · e3a392f · e3a392f
1 parent d8785f0
commit e3a392f
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/integration/odc/plugin.go b/core/integration/odc/plugin.go
@@ -259,12 +259,16 @@ func (p *Plugin) queryPartitionStatus() {
 					Info("ODC Partition state changed")
 
 				payload := map[string]interface{}{
-					"odcStatus": &response,
+					"oldState":         existingPartition.State,
+					"newState":         partitionInfo.State,
+					"partitionId":      partitionInfo.PartitionId.String(),
+					"ddsSessionId":     partitionInfo.DdsSessionId,
+					"ddsSessionStatus": partitionInfo.DdsSessionStatus,
 				}
 				payloadJson, _ := json.Marshal(payload)
 
 				the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{
-					Name:          "odc.queryPartitionStatus",
+					Name:          "odc.partitionStateChanged",
 					EnvironmentId: id.String(),
 					Payload:       string(payloadJson[:]),
 				})