This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new b225f60 change context type
new 79d6418 Merge pull request #16211 from [BEAM-13207][Playground]
Change context type
b225f60 is described below
commit b225f60d815f9ff2cfe76765b37396c26b4cf169
Author: daria-malkova <[email protected]>
AuthorDate: Mon Dec 13 16:24:37 2021 +0300
change context type
---
playground/backend/cmd/server/controller.go | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/playground/backend/cmd/server/controller.go
b/playground/backend/cmd/server/controller.go
index 64f2d3d..dcf80b4 100644
--- a/playground/backend/cmd/server/controller.go
+++ b/playground/backend/cmd/server/controller.go
@@ -80,8 +80,7 @@ func (controller *playgroundController) RunCode(ctx
context.Context, info *pb.Ru
return nil, errors.InternalError("Run code()", "Error during
set expiration to cache: %s", err.Error())
}
- // TODO change using of context.TODO() to context.Background()
- go code_processing.Process(context.TODO(), controller.cacheService, lc,
pipelineId, &controller.env.ApplicationEnvs, &controller.env.BeamSdkEnvs,
info.PipelineOptions)
+ go code_processing.Process(context.Background(),
controller.cacheService, lc, pipelineId, &controller.env.ApplicationEnvs,
&controller.env.BeamSdkEnvs, info.PipelineOptions)
pipelineInfo := pb.RunCodeResponse{PipelineUuid: pipelineId.String()}
return &pipelineInfo, nil
