From 788722c81b13cf4c8278cb3eb14fc45a4fd344c5 Mon Sep 17 00:00:00 2001 From: Ivan Chupin Date: Tue, 17 Jun 2025 13:01:01 +0200 Subject: [PATCH] flush pending queue during manual flush request --- .../wfm/topology/reroute/service/RerouteQueueService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java b/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java index 1ffefe67d0..b627446fbe 100644 --- a/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java +++ b/src-java/reroute-topology/reroute-storm-topology/src/main/java/org/openkilda/wfm/topology/reroute/service/RerouteQueueService.java @@ -159,7 +159,8 @@ public void processManualFlushRequest(String flowId, FlowThrottlingData throttli FlowResponse flowData; RerouteQueue rerouteQueue = getRerouteQueue(flowId); if (rerouteQueue.hasInProgress()) { - rerouteQueue.putToInProgress(null); + rerouteQueue.setInProgress(null); + rerouteQueue.setPending(null); flowData = new FlowResponse(FlowDto.builder() .state(FlowState.IN_PROGRESS) .statusInfo("Reroute has flushed").build());