kestra-io / kestra-io/plugin-nats
plugin-nats: kill()/stop() not implemented on killable/pollable tasks
- Dominant language
- Java
- Stars
- 3
- Forks
- 8
- Avg merge
- 3d 16h
- Merged PRs (30d)
- 4
Description
Sub-issue of kestra-io/kestra-ee#10964.
**Tasks:** io.kestra.plugin.nats.core.Consume
**Why:** Long-lived NATS consume loop; no kill()/stop() to close the subscription early.
**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
Start with io.kestra.plugin.nats.core.Consume and inspect the killable or pollable task lifecycle. Use io.kestra.plugin.gcp.bigquery.AbstractBigquery as the reference implementation, then verify that stopping or killing the task cancels the poll loop and closes the NATS consumer or remote job.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- backend, distributed-systems
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Active
- Clarity
- Mostly clear
- Newbie friendliness
- 68/100