(ctx context.Context)
| 211 | } |
| 212 | |
| 213 | func (m *ImportTask) Progress(ctx context.Context) queue.Progresses { |
| 214 | m.Lock() |
| 215 | defer m.Unlock() |
| 216 | return m.progress |
| 217 | } |
| 218 | |
| 219 | func (m *ImportTask) Summarize(hasher hashid.Encoder) *queue.Summary { |
| 220 | // unmarshal state |