Merge branch 'main' into chore/update-plugin-categories

Author: fdelbrayelle

.github/ISSUE_TEMPLATE/bug.yml

@@ -1,55 +1,26 @@
-name: Bug Report
+name: Bug report
 description: File a bug report
 body:
   - type: markdown
     attributes:
       value: |
-        Thanks for reporting an issue, please review the task list below before submitting the issue. Your issue report will be closed if the issue is incomplete and the below tasks not completed.
-
-        NOTE: If you are unsure about something and the issue is more of a question a better place to ask questions is on [Slack](https://kestra.io/slack).
+        Thanks for reporting an issue! Please provide a [Minimal Reproducible Example](https://stackoverflow.com/help/minimal-reproducible-example) and share any additional information that may help reproduce, troubleshoot, and hopefully fix the issue, including screenshots, error traceback, and your Kestra server logs. For quick questions, you can contact us directly on [Slack](https://kestra.io/slack).
   - type: textarea
     attributes:
-      label: Expected Behavior
-      description: A concise description of what you expected to happen.
-      placeholder: Tell us what should happen
+      label: Describe the issue
+      description: A concise description of the issue and how we can reproduce it.
+      placeholder: Describe the issue step by step
     validations:
-      required: false
-  - type: textarea
-    attributes:
-      label: Actual Behaviour
-      description: A concise description of what you're experiencing.
-      placeholder: Tell us what happens instead
-    validations:
-      required: false
-  - type: textarea
-    attributes:
-      label: Steps To Reproduce
-      description: Steps to reproduce the behavior.
-      placeholder: |
-        1. In this environment...
-        2. With this config...
-        3. Run '...'
-        4. See error...
-    validations:
-      required: false
+      required: true
   - type: textarea
     attributes:
-      label: Environment Information
+      label: Environment
       description: Environment information where the problem occurs.
       value: |
-        - Kestra Version:
-        - Plugin version: 
-        - Operating System (OS / Docker / Kubernetes):
-        - Java Version (If not docker):
-    validations:
-      required: true
-  - type: textarea
-    attributes:
-      label: Example flow
-      description: Example flow source.
-      placeholder: |
-        If relevant, an example flow
+        - Kestra Version: develop
     validations:
       required: false
 labels:
-  - bug
+  - area/plugin
+type: Bug
+projects: ["kestra-io/15"]

.github/ISSUE_TEMPLATE/config.yml

@@ -2,3 +2,4 @@ contact_links:
   - name: Chat
     url: https://kestra.io/slack
     about: Chat with us on Slack.
+blank_issues_enabled: false

.github/ISSUE_TEMPLATE/feature.yml

@@ -1,15 +1,13 @@
 name: Feature request
 description: Create a new feature request
 body:
-  - type: markdown
-    attributes:
-      value: |
-        Please describe the feature you want for Kestra to implement, before that check if there is already an existing issue to add it.
   - type: textarea
     attributes:
       label: Feature description
-      placeholder: Tell us what feature you would like for Kestra to have and what problem is it going to solve
+      placeholder: Tell us more about your feature request
     validations:
       required: true
 labels:
-  - enhancement
+  - area/plugin
+type: Feature
+projects: ["kestra-io/15"]

.github/ISSUE_TEMPLATE/other.yml

@@ -40,47 +40,4 @@ Thank you for your contribution. ❤️  -->
 
 ### Contributor Checklist ✅
 
-- [ ] PR Title and commits follows [conventional commits](https://www.conventionalcommits.org/en/v1.0.0/)
-- [ ] Add a `closes #ISSUE_ID` or `fixes #ISSUE_ID` in the description if the PR relates to an opened issue.
-- [ ] Documentation updated (plugin docs from `@Schema` for properties and outputs, `@Plugin` with examples, `README.md` file with basic knowledge and specifics).
-- [ ] Setup instructions included if needed (API keys, accounts, etc.).
-- [ ] Prefix all rendered properties by `r` not `rendered` (eg: `rHost`).
-- [ ] Use `runContext.logger()` to log enough important infos where it's needed and with the best level (DEBUG, INFO, WARN or ERROR).
-
-⚙️ **Properties**
-- [ ] Properties are declared with `Property<T>` carrier type, do **not** use `@PluginProperty`.
-- [ ] Mandatory properties must be annotated with `@NotNull` and checked during the rendering.
-- [ ] You can model a JSON thanks to a simple `Property<Map<String, Object>>`.
-
-🌐 **HTTP**
-- [ ] Must use Kestra’s internal HTTP client from `io.kestra.core.http.client`
-
-📦 **JSON**
-- [ ] If you are serializing response from an external API, you may have to add a `@JsonIgnoreProperties(ignoreUnknown = true)` at the mapped class level. So that we will avoid to crash the plugin if the provider add a new field suddenly.
-- [ ] Must use Jackson mappers provided by core (`io.kestra.core.serializers`)
-
-✨ **New plugins / subplugins**
-- [ ] Make sure your new plugin is configured like mentioned [here](https://kestra.io/docs/plugin-developer-guide/gradle#mandatory-configuration).
-- [ ] Add a `package-info.java` under each sub package respecting [this format](https://github.com/kestra-io/plugin-odoo/blob/main/src/main/java/io/kestra/plugin/odoo/package-info.java) and choosing the right category.
-- [ ] Every time you use `runContext.metric(...)` you have to add a `@Metric` ([see this doc](https://kestra.io/docs/plugin-developer-guide/document#document-the-plugin-metrics))
-- [ ] Docs don't support to have both tasks/triggers in the root package (e.g. `io.kestra.plugin.kubernetes`) and in a sub package (e.g. `io.kestra.plugin.kubernetes.kubectl`), whether it's: all tasks/triggers in the root package OR only tasks/triggers in sub packages.
-- [ ] Icons added in `src/main/resources/icons` in SVG format and not in thumbnail (keep it big):
-  - `plugin-icon.svg`
-  - One icon per package, e.g. `io.kestra.plugin.aws.svg`
-  - For subpackages, e.g. `io.kestra.plugin.aws.s3`, add `io.kestra.plugin.aws.s3.svg`
-    See example [here](https://github.com/kestra-io/plugin-elasticsearch/blob/master/src/main/java/io/kestra/plugin/elasticsearch/Search.java#L76).
-- [ ] Use `"{{ secret('YOUR_SECRET') }}"` in the examples for sensible infos such as an API KEY.
-- [ ] If you are fetching data (one, many or too many), you must add a `Property<FetchType> fetchType` to be able to use `FETCH_ONE`, `FETCH` and even `STORE` to store big amount of data in the internal storage.
-- [ ] Align the `"""` to close examples blocks with the flow id.
-- [ ] Update the existing `index.yaml` for the main plugin, and for each new subpackage add a metadata file named exactly after the subpackage (e.g. `s3.yaml` for `io.kestra.plugin.aws.s3`) under `src/main/resources/metadata/`, following the same schema.
-
-🧪 **Tests**
-- [ ] Unit Tests added or updated to cover the change (using the `RunContext` to actually run tasks).
-- [ ] Add sanity checks if possible with a YAML flow inside `src/test/resources/flows`.
-- [ ] Avoid disabling tests for CI. Instead, configure a local environment whenever it's possible with `.github/setup-unit.sh` (to be set executable with `chmod +x setup-unit.sh`) (which can be executed locally and in the CI) all along with a new `docker-compose-ci.yml` file (do **not** edit the existing `docker-compose.yml`). If needed, create an executable (`chmod +x cleanup-unit.sh`) `cleanup-unit.sh` to remove the potential costly resources (tables, datasets, etc).
-- [ ] Provide screenshots from your QA / tests locally in the PR description. The goal here is to use the JAR of the plugin and directly test it locally in Kestra UI to ensure it integrates well.
-
-📤 **Outputs**
-- [ ] Do not send back as outputs the same infos you already have in your properties.
-- [ ] If you do not have any output use `VoidOutput`.
-- [ ] Do not output twice the same infos (eg: a status code, an error code saying the same thing...).
+- [ ] I have read and followed the [plugin contribution guidelines](https://kestra.io/docs/plugin-developer-guide/contribution-guidelines)

.github/pull_request_template.md

@@ -1,11 +1,11 @@
 plugins {
-    id "com.vanniktech.maven.publish" version "0.35.0"
+    id "com.vanniktech.maven.publish" version "0.36.0"
     id "io.kestra.gradle.inject-bom-versions" version "1.0.0"
     id 'java-library'
     id "idea"
     id 'jacoco'
     id "com.adarshr.test-logger" version "4.0.0"
-    id "com.gradleup.shadow" version "9.3.0"
+    id "com.gradleup.shadow" version "9.3.1"
     id 'signing'
     id "com.github.ben-manes.versions" version "0.53.0"
     id 'net.researchgate.release' version '3.1.0'
@@ -53,7 +53,7 @@ dependencies {
     compileOnly'org.slf4j:slf4j-api'
 
     // libs included in the final jar
-    api group: 'com.couchbase.client', name: 'java-client', version: '3.10.0'
+    api group: 'com.couchbase.client', name: 'java-client', version: '3.11.0'
 }
 
 

build.gradle

@@ -1,3 +1,3 @@
 description=Integrate Couchbase NoSQL database operations into your Kestra flows for efficient data management, real-time analytics, and improved performance across your data-driven applications.
-version=1.1.2-SNAPSHOT
-kestraVersion=1.2.3
+version=1.1.3-SNAPSHOT
+kestraVersion=1.2.3

gradle.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-9.1.0-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-9.3.1-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

gradle/wrapper/gradle-wrapper.properties

@@ -5,19 +5,22 @@
 
 public interface CouchbaseConnectionInterface {
     @Schema(
-        title = "Connection string used to locate the Couchbase cluster."
+        title = "Couchbase connection string",
+        description = "Full connection string (e.g., couchbase://host) rendered with flow variables before opening the cluster."
     )
     @PluginProperty(dynamic = true)
     String getConnectionString();
 
     @Schema(
-        title = "Plaintext authentication username."
+        title = "Cluster username",
+        description = "Renderable username for authenticating to the cluster; store sensitive values in secrets."
     )
     @PluginProperty(dynamic = true)
     String getUsername();
 
     @Schema(
-        title = "Plaintext authentication password."
+        title = "Cluster password",
+        description = "Renderable password for authenticating to the cluster; prefer secret storage."
     )
     @PluginProperty(dynamic = true)
     String getPassword();

src/main/java/io/kestra/plugin/couchbase/CouchbaseConnectionInterface.java

@@ -30,7 +30,8 @@
 @Getter
 @NoArgsConstructor
 @Schema(
-    title = "Query a Couchbase database with N1QL."
+    title = "Run Couchbase N1QL and capture results",
+    description = "Executes the rendered N1QL statement on the target cluster. Defaults to STORE, writing the full result set to Kestra internal storage; use FETCH to return all rows inline or FETCH_ONE for just the first row. Parameters can be named or positional."
 )
 @Plugin(
     examples = {
@@ -117,26 +118,26 @@ else if (parameters instanceof List) {
     @Getter
     public static class Output implements io.kestra.core.models.tasks.Output {
         @Schema(
-            title = "List containing the fetched data.",
-            description = "Only populated if using `FETCH`."
+            title = "All rows returned",
+            description = "Present when fetchType resolves to FETCH; each row is returned as a JSON map."
         )
         private List<Map<String, Object>> rows;
 
         @Schema(
-            title = "Map containing the first row of fetched data.",
-            description = "Only populated if using `FETCH_ONE`."
+            title = "First row returned",
+            description = "Present when fetchType resolves to FETCH_ONE; null if the query returns no rows."
         )
         private Map<String, Object> row;
 
         @Schema(
-            title = "The URI of the stored result in Kestra's internal storage.",
-            description = "Only populated if using `STORE`."
+            title = "Stored result URI",
+            description = "Present when fetchType resolves to STORE; points to the Kestra internal storage object containing all rows."
         )
         private URI uri;
 
         @Schema(
-            title = "The number of rows to be fetched.",
-            description = "Only populated if `fetchType` is 'FETCH' or 'STORE'."
+            title = "Number of rows returned",
+            description = "Set when fetchType is FETCH or STORE; useful for branching or triggers."
         )
         private Long size;
     }