diff --git a/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt b/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt
index 42881896db..aac8f3901f 100644
--- a/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt
+++ b/node/src/main/kotlin/net/corda/node/utilities/ANSIProgressObserver.kt
@@ -40,6 +40,7 @@ class ANSIProgressObserver(val smm: StateMachineManager) {
 
     private fun removeFlowLogic(flowLogic: FlowLogic<*>) {
         state.locked {
+            pending.remove(flowLogic)
             if (currentlyRendering == flowLogic) {
                 wireUpProgressRendering()
             }