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 c57c983 Merge pull request #16074 from [BEAM-13323][Playground]
[Bugfix] Fix CI checks
c57c983 is described below
commit c57c983c8ae7d84926f9cf42f7c40af8eaf60545
Author: Aydar Zainutdinov <[email protected]>
AuthorDate: Sun Nov 28 05:35:09 2021 +0300
Merge pull request #16074 from [BEAM-13323][Playground] [Bugfix] Fix CI
checks
* [Playground][BEAM-12941][Bugfix] Fix workflows for playground
applications (#83)
* Update workflows for playground
* Attempt to fix tests
* Remove continue on error to catch errors
* Fix linter problem for backend dockerfile
* Update folder to run backend go linter
* Moved flutter test to execution via gradle tasks
* Revert "[Playground][BEAM-12941][Bugfix] Fix workflows for playground
applications (#83)" (#88)
This reverts commit b73f5f70ac4184b56a0a03922731c5f2f69b9566.
* [BEAM-13323][Playground]
added processing of err case for utils.SetToCache() method in
GetRunOutput() api method
Co-authored-by: Sergey Kalinin <[email protected]>
Co-authored-by: Ilya <[email protected]>
Co-authored-by: daria.malkova <[email protected]>
Co-authored-by: Pavel Avilov <[email protected]>
Co-authored-by: Aydar Farrakhov <[email protected]>
---
playground/backend/cmd/server/controller.go | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/playground/backend/cmd/server/controller.go
b/playground/backend/cmd/server/controller.go
index c428234..02010cd 100644
--- a/playground/backend/cmd/server/controller.go
+++ b/playground/backend/cmd/server/controller.go
@@ -124,7 +124,9 @@ func (controller *playgroundController) GetRunOutput(ctx
context.Context, info *
newRunOutput := ""
if len(runOutput) > lastIndex {
newRunOutput = runOutput[lastIndex:]
- utils.SetToCache(ctx, controller.cacheService, pipelineId,
cache.RunOutputIndex, lastIndex+len(newRunOutput))
+ if err := utils.SetToCache(ctx, controller.cacheService,
pipelineId, cache.RunOutputIndex, lastIndex+len(newRunOutput)); err != nil {
+ return nil, errors.InternalError("GetRunOutput", "Error
during set value to cache: "+err.Error())
+ }
}
pipelineResult := pb.GetRunOutputResponse{Output: newRunOutput}
