From e3ddd9d5f67d99c86f67afb74070d6a88c01594c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michal=20Tich=C3=A1k?= Date: Mon, 30 Sep 2024 14:03:34 +0200 Subject: [PATCH] removed DCS EOF kafka message in PFR and EOR --- core/integration/dcs/plugin.go | 22 ---------------------- 1 file changed, 22 deletions(-) diff --git a/core/integration/dcs/plugin.go b/core/integration/dcs/plugin.go index 524fd220..4f9ea3fb 100644 --- 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) {