class ProgressEventsWithStatus extends ProgressEvents {
    @Override
    protected void otherEvent(ProgressEvent event, Operation operation) {
        if (event instanceof StatusEvent) {
            operation.statusEvents.add(new OperationStatus(event))
        } else {
            super.otherEvent(event, operation)
        }
    }

                    continue
                }
                assert running.containsKey(descriptor)
                def operation = operations.find { it.descriptor == event.descriptor }
                otherEvent(event, operation)
            }
        }
        assert running.size() == 0: "Not all operations completed: ${running.values()}, events: ${events}"

        dirty = false
    }