kestra-io / kestra-io/plugin-gcp
plugin-gcp: kill()/stop() not implemented on killable/pollable tasks
- Dominant language
- Java
- Stars
- 15
- Forks
- 27
- Avg merge
- 1d 48m
- Merged PRs (30d)
- 11
Description
Sub-issue of kestra-io/kestra-ee#10964.
**Tasks:** io.kestra.plugin.gcp.dataform.InvokeWorkflow, io.kestra.plugin.gcp.pubsub.Consume
**Why:** InvokeWorkflow polls a Dataform workflow invocation to completion; Consume runs a long-lived Pub/Sub pull loop. Neither overrides kill()/stop().
**Fix:** override `kill()` and/or `stop()` on these task classes to cancel the poll loop / close the consumer / cancel the remote job. See `io.kestra.plugin.gcp.bigquery.AbstractBigquery` for a reference implementation.
Contributor guide
No contributing guide indexed for this repository
Research direction
Read the InvokeWorkflow and Consume task classes, then compare their lifecycle handling with io.kestra.plugin.gcp.bigquery.AbstractBigquery. Confirm how kill() and stop() should cancel the Dataform poll loop, close the Pub/Sub consumer, or cancel the remote job. Done means both tasks respond correctly to the relevant lifecycle calls without leaving work running.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- gcp, java
- Domain
- backend, cloud
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Active
- Clarity
- Mostly clear
- Newbie friendliness
- 72/100