170
171
// Remove this revision from in-progress tracking for this build
172
>
if revisions, ok := d.State.PropagatingRevisions[buildID]; ok {
workflow.go
173
>
found := false
174
>
// Find and remove the revision number
175
>
filteredRevisions := make([]int64, 0, len(revisions.RevisionNumbers))
176
>
for _, rev := range revisions.RevisionNumbers {
177
>
if rev != revisionNumber {
178
filteredRevisions = append(filteredRevisions, rev)
180
>
found = true
181
>
}
182
}
184
d.logger.Error("Received propagation complete signal, but this propagation is not in-progress",
185
"revision", revisionNumber,