Skip to content

Commit 949f11c

Browse files
authored
Fix passing incorrect ctx in AWS & GCP storage (#844)
1 parent 7625431 commit 949f11c

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

storage/aws/aws.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,11 +212,11 @@ func (s *Storage) newAppender(ctx context.Context, o objStore, seq sequencer, op
212212
logStore := &logResourceStore{
213213
objStore: o,
214214
entriesPath: opts.EntriesPath(),
215-
integratedSize: func(context.Context) (uint64, error) {
215+
integratedSize: func(ctx context.Context) (uint64, error) {
216216
s, _, err := seq.currentTree(ctx)
217217
return s, err
218218
},
219-
nextIndex: func(context.Context) (uint64, error) {
219+
nextIndex: func(ctx context.Context) (uint64, error) {
220220
return seq.nextIndex(ctx)
221221
},
222222
}

storage/gcp/gcp.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -261,11 +261,11 @@ func (s *Storage) newAppender(ctx context.Context, o objStore, seq *spannerCoord
261261

262262
reader := &LogReader{
263263
lrs: *a.logStore,
264-
integratedSize: func(context.Context) (uint64, error) {
264+
integratedSize: func(ctx context.Context) (uint64, error) {
265265
s, _, err := a.sequencer.currentTree(ctx)
266266
return s, err
267267
},
268-
nextIndex: func(context.Context) (uint64, error) {
268+
nextIndex: func(ctx context.Context) (uint64, error) {
269269
return a.sequencer.nextIndex(ctx)
270270
},
271271
}
@@ -1333,7 +1333,7 @@ func (s *Storage) MigrationWriter(ctx context.Context, opts *tessera.MigrationOp
13331333

13341334
r := &LogReader{
13351335
lrs: *m.logStore,
1336-
integratedSize: func(context.Context) (uint64, error) {
1336+
integratedSize: func(ctx context.Context) (uint64, error) {
13371337
s, _, err := m.sequencer.currentTree(ctx)
13381338
return s, err
13391339
},

0 commit comments

Comments
 (0)