kestra-io / kestra-io/plugin-gcp

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

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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.