| Index: logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| diff --git a/logdog/appengine/coordinator/mutations/createArchiveTask.go b/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| index 16220227ee14d3f03a771f53100d7df359c9ba07..5e0530cec2d97d255bd541b502da21f1989bd09d 100644
|
| --- a/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| +++ b/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| @@ -47,6 +47,11 @@ func (m *CreateArchiveTask) RollForward(c context.Context) ([]tumble.Mutation, e
|
| log.WithError(err).Errorf(c, "Failed to get archival publisher.")
|
| return nil, err
|
| }
|
| + defer func() {
|
| + if err := ap.Close(); err != nil {
|
| + log.WithError(err).Warningf(c, "Failed to close archival publisher.")
|
| + }
|
| + }()
|
|
|
| // Get the log stream.
|
| state := m.logStream().State(c)
|
|
|