| Index: logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| diff --git a/logdog/appengine/coordinator/mutations/createArchiveTask.go b/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| index 5e0530cec2d97d255bd541b502da21f1989bd09d..6696acfe93e4d7f6a31b27df9ce7d2c4bc33eb03 100644
|
| --- a/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| +++ b/logdog/appengine/coordinator/mutations/createArchiveTask.go
|
| @@ -102,8 +102,8 @@ func (m *CreateArchiveTask) ProcessAfter() time.Time { return m.Expiration }
|
| func (m *CreateArchiveTask) HighPriority() bool { return false }
|
|
|
| // TaskName returns the task's name, which is derived from its log stream ID.
|
| -func (m *CreateArchiveTask) TaskName(c context.Context) (*ds.Key, string) {
|
| - return ds.KeyForObj(c, m.logStream()), fmt.Sprintf("archive-expired-%s", m.ID)
|
| +func (m *CreateArchiveTask) TaskName(c context.Context) string {
|
| + return fmt.Sprintf("archive-expired-%s", m.ID)
|
| }
|
|
|
| // logStream returns the log stream associated with this task.
|
|
|