File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -467,7 +467,10 @@ func (i *Ingester) v2TransferOut(ctx context.Context) error {
467
467
// requests will be accepted because the "stopped" flag has already been set.
468
468
level .Info (util .Logger ).Log ("msg" , "waiting for in-flight write requests to complete" )
469
469
470
- waitCtx , waitCancel := context .WithTimeout (ctx , 10 * time .Second )
470
+ // Do not use the parent context cause we don't want to interrupt while waiting
471
+ // for in-flight requests to complete if the parent context is cancelled, given
472
+ // this logic run only once.
473
+ waitCtx , waitCancel := context .WithTimeout (context .Background (), 10 * time .Second )
471
474
defer waitCancel ()
472
475
473
476
if err := util .WaitGroup (waitCtx , & i .TSDBState .inflightWriteReqs ); err != nil {
You can’t perform that action at this time.
0 commit comments