Commit eb2642fd authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ba630738
...@@ -161,12 +161,9 @@ func (d *Storage) Close() (err error) { ...@@ -161,12 +161,9 @@ func (d *Storage) Close() (err error) {
errBase := d.base.Close() errBase := d.base.Close()
d.watchCancel() d.watchCancel()
errWatch := d.watchWG.Wait() _ = d.watchWG.Wait() // ignore error - it goes to watchq and op errors
if errors.Is(errWatch, context.Canceled) { // we canceled it
errWatch = nil
}
return xerr.Merge(errWatch, errδ, errBase) return xerr.Merge(errδ, errBase)
} }
// Sync implements zodb.IStorageDriver . // Sync implements zodb.IStorageDriver .
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment