kestra-io / kestra-io/plugin-nats

plugin-nats: kill()/stop() not implemented on killable/pollable tasks

Open
#176 0 comments 0 reactions 0 assignees View on GitHub
area/plugin kind/cooldown
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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.