do not wait on deleted collections (#1953)
## Type of change - [x] 🐛 Bugfix ## Issue(s) * #1950 ## Test Plan - [x] 💪 Manual
This commit is contained in:
parent
442686e51e
commit
eacb638099
@ -56,8 +56,16 @@ func (gc *GraphConnector) DataCollections(
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
for range colls {
|
for _, c := range colls {
|
||||||
gc.incrementAwaitingMessages()
|
// kopia doesn't stream Items() from deleted collections,
|
||||||
|
// and so they never end up calling the UpdateStatus closer.
|
||||||
|
// This is a brittle workaround, since changes in consumer
|
||||||
|
// behavior (such as calling Items()) could inadvertently
|
||||||
|
// break the process state, putting us into deadlock or
|
||||||
|
// panics.
|
||||||
|
if c.State() != data.DeletedState {
|
||||||
|
gc.incrementAwaitingMessages()
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return colls, nil
|
return colls, nil
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user