You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2021/12/13 14:26:04 UTC
[beam] branch master updated: change context type
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 <da...@akvelon.com>
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