From c0e21337eb117636dd1e5e9d41b2e076d4e785f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michal=20Tich=C3=A1k?= Date: Fri, 20 Sep 2024 15:40:07 +0200 Subject: [PATCH] removing kafka event in DCS plugin for EOF received from DCS --- core/integration/dcs/plugin.go | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/core/integration/dcs/plugin.go b/core/integration/dcs/plugin.go index 500fae2a..5a35a307 100644 --- a/core/integration/dcs/plugin.go +++ b/core/integration/dcs/plugin.go @@ -1041,7 +1041,6 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { }) } return - } stack["StartOfRun"] = func() (out string) { // must formally return string even when we return nothing var err error @@ -1416,17 +1415,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: StartOfRun", - OperationStepStatus: pb.OpStatus_DONE_ERROR, - EnvironmentId: envId, - Payload: string(payloadJson[:]), - Error: logMsg, - }) - break // no more data } if errors.Is(err, context.DeadlineExceeded) { @@ -1663,7 +1651,6 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { dcsopOk = false dcsFailedEcsDetectors = append(dcsFailedEcsDetectors, dcsToEcsDetector(v)) } - } if dcsopOk { p.pendingEORs[envId] = runNumber64