removed DCS EOF kafka message in PFR and EOR

AliceO2Group · Sep 30, 2024 · e3ddd9d · e3ddd9d
1 parent 4768984
commit e3ddd9d
Showing 1 changed file with 0 additions and 22 deletions.
diff --git a/core/integration/dcs/plugin.go b/core/integration/dcs/plugin.go
@@ -760,17 +760,6 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 				log.WithField("partition", envId).
 					Debug(logMsg)
 
-				the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{
-					Name:                call.GetName(),
-					OperationName:       call.Func,
-					OperationStatus:     pb.OpStatus_ONGOING,
-					OperationStep:       "perform DCS call: PrepareForRun",
-					OperationStepStatus: pb.OpStatus_DONE_ERROR,
-					EnvironmentId:       envId,
-					Payload:             string(payloadJson[:]),
-					Error:               logMsg,
-				})
-
 				break // no more data
 			}
 			if errors.Is(err, context.DeadlineExceeded) {
@@ -1977,17 +1966,6 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) {
 					WithField("run", runNumber64).
 					Debug(logMsg)
 
-				the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{
-					Name:                call.GetName(),
-					OperationName:       call.Func,
-					OperationStatus:     pb.OpStatus_ONGOING,
-					OperationStep:       "perform DCS call: EndOfRun",
-					OperationStepStatus: pb.OpStatus_DONE_ERROR,
-					EnvironmentId:       envId,
-					Payload:             string(payloadJson[:]),
-					Error:               logMsg,
-				})
-
 				break // no more data
 			}
 			if errors.Is(err, context.DeadlineExceeded) {