[
https://issues.apache.org/jira/browse/BEAM-13110?focusedWorklogId=680236&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-680236
]
ASF GitHub Bot logged work on BEAM-13110:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 11/Nov/21 11:34
Start Date: 11/Nov/21 11:34
Worklog Time Spent: 10m
Work Description: AydarZaynutdinov commented on a change in pull request
#15926:
URL: https://github.com/apache/beam/pull/15926#discussion_r747424500
##########
File path: playground/backend/cmd/server/controller.go
##########
@@ -272,6 +282,9 @@ func processCode(ctx context.Context, cacheService
cache.Cache, lc *fs_tool.Life
errorChannel := make(chan error, 1)
dataChannel := make(chan interface{}, 1)
successChannel := make(chan bool, 1)
+ cancelChan := make(chan bool, 1)
Review comment:
Renamed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 680236)
Time Spent: 1h 40m (was: 1.5h)
> [Playground] Playground pipeline cancelation
> --------------------------------------------
>
> Key: BEAM-13110
> URL: https://issues.apache.org/jira/browse/BEAM-13110
> Project: Beam
> Issue Type: Sub-task
> Components: beam-playground
> Reporter: Aydar Zaynutdinov
> Assignee: Aydar Zaynutdinov
> Priority: P3
> Labels: beam-playground-backend
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
> * Add status Canceled
> * Add new API method Cancel:
> this method should set pipelinedId:canceled:true to cache
> * Update code processing:
> If the pipelinedId:canceled is true, then
> ** set status Canceled
> ** stop processes (which were generated to process code) for pipelineId
> ** clean resources (folders and files to process code) for pipelineId
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
