878 Commits

Author SHA1 Message Date
Roman Acevedo
e0e745cb91 Revert "fix(api): add netty-codec-multipart-vintage"
This reverts commit 44d0c10713.
2025-12-19 15:26:15 +01:00
Florian Hussonnois
352d4eb194 chore(test): use MicronautTest when possible 2025-12-19 14:45:27 +01:00
Loïc Mathieu
44d0c10713 fix(api): add netty-codec-multipart-vintage
This should fix the multipart codec issue of Netty.

Fixes #9743
2025-12-18 17:12:55 +01:00
mustafatarek
f409657e8a feat(core): improve exception handling and validation with Inputs/Outputs
- Added InputOutputValidationException to represent Inputs/Outputs
  validation issues and added handler to it in ErrorsController
- Added support for throwing multiple constraint violations for the same
  input
- Added support for throwing multiple constraints at MultiselectInput
- Refactored exception handling at FlowInputOutput
- Added merge() function to combine constraint violation messages and
  added test for it at InputsTest
- Fixed the failed tests
2025-12-18 15:44:34 +01:00
Loïc Mathieu
7ea95f393e feat(execution): add a system.from label
Closes https://github.com/kestra-io/kestra-ee/issues/4699
2025-12-17 15:49:33 +01:00
Pratik Dey
048dcb80cc fix: Webhook-triggered executions do not generate system.correlationId label while direct API executions do 2025-12-15 12:37:23 +01:00
Loïc Mathieu
86e08d71dd fix(test): makes TracesTest.runningAFlowShouldGenerateTraces more tolerant on the number of traces
Rarely, in the CI, only 6 traces are seen most probably due to the asynchronous nature of OpenTelemetry
2025-12-11 14:55:46 +01:00
Loïc Mathieu
eb12832b1e feat(system): add a boolean in the config to know if the concurrency view is enabled
Part-of: https://github.com/kestra-io/kestra-ee/issues/5882
2025-12-11 14:54:09 +01:00
Loïc Mathieu
56febfb415 fix(executions): don't remove worker task result for killed execution
As killing an executuion is asynchronous, it is inherently racy.
So when we kill an execution it move to the rerminal state which then will remove any worker task result to purge eagerly the queue table.

But if such worker task result arrives late and was not already processed by the executor, it will be purged before ever been able to be processed so the task would nevert be updated as KILLED.

Note: this may un-flaky some falky unit tests

Fixes https://github.com/kestra-io/kestra-ee/issues/6040
2025-12-10 17:27:11 +01:00
mustafatarek
2951f4b4bc feat(tests): add test coverage for json input type parsing as map 2025-12-10 16:31:14 +01:00
mustafatarek
42dc3b930c fix(tests): pass previewInternalStorageFileFromExecution() test 2025-12-10 16:31:14 +01:00
mustafatarek
b3b2ef1b5a fix(tests): pass inputs() test 2025-12-10 16:31:14 +01:00
mustafatarek
596a26a137 fix(tests): pass all failed tests 2025-12-10 16:31:14 +01:00
mustafatarek
8a9a1df436 fix(tests): fix failed tests after adding another input 2025-12-10 16:31:14 +01:00
Nicolas K.
008404e442 feat(filters): add new operation to filters (#13424)
* feat(filters): add new operation to filters

* feat(filters): add flowId to flow search

* fix(test): fix unit test

---------

Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
2025-12-10 15:17:32 +01:00
kkash08
5b597b9520 Fix ZIP download so that file extension remains .yaml 2025-12-02 09:24:55 +01:00
brian.mulier
682d258e7b feat(ns-files): add a metadata layer on top for better performance & versioned ns files
part of https://github.com/kestra-io/kestra/issues/5617
2025-12-01 18:13:49 +01:00
Loïc Mathieu
496e01eb3e feat(executions): add support to ACL check inside the run context
Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
2025-12-01 10:29:38 +01:00
Florian Hussonnois
5a8552ad36 refactor(core): remove LogService
Move static methods to Logs utility class
Move purge method to existing ExecutionLogService
2025-11-28 17:48:23 +01:00
brian.mulier
8bd5593b2d fix(tests): export path was wrong 2025-11-27 19:23:17 +01:00
brian.mulier
15da58dbf4 fix(tests): use another db name on webserver to avoid colliding with repositories 2025-11-27 19:23:17 +01:00
brian.mulier
c3d94dc8ff fix(tests): remove JdbcTestUtils.drop usages as it defeats concurrent test runs 2025-11-27 19:23:17 +01:00
YannC
546039e30a fix(webserver): export test with correct path + DateField for execution export (#13197) 2025-11-27 15:43:03 +01:00
YannC
7fd16b24e0 feat: allows to export flows/triggers/executions as a streamed CSV files (#13137) 2025-11-26 14:11:14 +01:00
Nicolas K.
527d80cd74 fix(tests): failing unit test flowProperties (#13138)
Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
2025-11-25 10:29:51 +01:00
Florian Hussonnois
eb51c5be37 feat(flows): add new check conditions
Adds new property 'checks' on flow in order to allow
pre-conditions to be evaluated before execution

Fixes: kestra-io/kestra-ee#5759
2025-11-21 14:25:01 +01:00
YannC
7fa14eb3f5 chore(API): apiResponse annotation for type return (#13088) 2025-11-20 09:47:32 +01:00
Nicolas K.
105b1b36e5 feat(flows): improve human task in bulk method, kill and force run (#13067)
Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
2025-11-19 14:53:59 +01:00
Loïc Mathieu
1d1a065833 fix(tests): lower termination grace period
If a test mis-behave, for ex starting an execution but not terminating it, as the default termination grace period is 5mn it can take very long time to wait for post-test terminaison.
Switching to a termination grace period of 5s may help.

I also detect that the ExecutionControllerRunner test when launching the test suite, would not properly kill the `sleep-long` flow so waiting for it to complete, or the termination grace period. When a test that use this flow is launched separatly it works properly. As a safety net I reduce the sleep from 5mn to 30s.
2025-11-19 11:58:06 +01:00
YannC
6e0197b542 feat: allows importFlows endpoint to be able to throw when having an invalid flow (#12995) 2025-11-18 09:33:32 +01:00
YannC
6918d5d512 feat: add annotation for multipart body on resumeExecution to have it inside SDK (#13003) 2025-11-18 09:33:21 +01:00
Loïc Mathieu
3b08c51158 chore(test): add tests for OpenTelemetry traces
Part-of:  #6879
2025-11-17 10:01:24 +01:00
Loïc Mathieu
9957b1659e fix(flow): flow trigger with both conditions and preconditions
When a flow have both a condition and a precondition, the condition was evaluated twice which lead to double execution triggered.

Fixes
2025-11-14 16:35:15 +01:00
YannC
c9559b60ca feat: set version as Kestra version in openapi spec (#12932) 2025-11-13 14:30:47 +01:00
Hemant M Mehta
073891e1a5 feat(triggers): delete triggers (#11758)
closes: #11386

---------

Co-authored-by: brian.mulier <bmmulier@hotmail.fr>
2025-11-06 16:59:02 +01:00
Piyush Bhaskar
0b6a4d2520 Revert "fix(core): apply timeRange filter in triggers (#12721)" (#12763) 2025-11-06 18:55:41 +05:30
Piyush Bhaskar
4c58a646c9 fix(core): apply timeRange filter in triggers (#12721) 2025-11-06 16:28:35 +05:30
Loïc Mathieu
9d3d40ade8 fix(system): trigger an execution once per condition on flow triggers
Fixes #12560
2025-11-05 15:30:26 +01:00
YannC
190bf6f3db fix: set FlowWithSource as implementation for getFlow method (#12644) 2025-11-04 16:16:54 +01:00
Roman Acevedo
18b6b4ce5d test(kv): plain text header is sent now 2025-11-04 15:16:18 +01:00
YannC
f164cddf7a Fix/sdk changes (#12411) (#12617)
* Fix/sdk changes (#12411)

* fix: kv controller remove namespace check

* clean(API): add query to filter parameter

* fix: flow update not deprecated

* clean(API): add deprecated on open api

* feat: executions annotations for skipping, follow method generation in sdk

* feat: add typing indication to validateTask

* fix(flowController): set correct hidden for json method in

* fix: optional params in delete executions endpoints

* fix: inputs/outputs as object

* change KV schema type to be object

* add back , deprecated = false on flow update, otherwise its marked as deprecated

* Revert "add back , deprecated = false on flow update, otherwise its marked as deprecated"

This reverts commit 3772404b68f14f0a80af9e0adb9952d58e9102b4.

* feat(API): add multipart to openAPI

* feat(API): add multipart to openAPI

* fix: only use plain-text for setKeyValue endpoint

* fix: KV command test

* chore: add multipart vendor annotations for custom generation on SDK

---------

Co-authored-by: YannC. <ycoornaert@kestra.io>
Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>

* fix: kv test remove content type

---------

Co-authored-by: Roman Acevedo <roman.acevedo62@gmail.com>
Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
2025-11-04 08:37:08 +01:00
Krie
e116186201 feat: make charts default duration configurable, add kestra.ui.charts… (#12599)
* feat: make charts default duration configurable, add kestra.ui.charts.default-duration config parameter (default: PT720H/30 days)

* Update cli/src/main/resources/application.yml

Co-authored-by: YannC <37600690+Skraye@users.noreply.github.com>

* Update ui/src/components/flows/FlowRoot.vue

Co-authored-by: YannC <37600690+Skraye@users.noreply.github.com>

* Update ui/src/routes/routes.js

Co-authored-by: YannC <37600690+Skraye@users.noreply.github.com>

* feat: set P30D instead of PT720H for readability

---------

Co-authored-by: YannC <37600690+Skraye@users.noreply.github.com>
Co-authored-by: YannC. <ycoornaert@kestra.io>
2025-11-03 09:21:39 +01:00
Loïc Mathieu
e2e4335771 fix(flows): fail flow validation for duplicate preconditions ID 2025-10-31 16:22:13 +01:00
Loïc Mathieu
e025677e70 fix(executions): set the execution to KILLING and not RESTARTED when killing a paused flow
Fixes https://github.com/kestra-io/kestra/issues/12417
2025-10-30 18:11:17 +01:00
Loïc Mathieu
9920d190c8 feat(system): add an administration page for concurrency limit
Closes  #11250
2025-10-30 17:49:33 +01:00
brian.mulier
d9144c8c4f feat(core): introduce KV Metadata in-repository storing (#12342)
part of https://github.com/kestra-io/kestra/issues/12341
2025-10-29 17:18:43 +01:00
Loïc Mathieu
55a8896181 chore(tests): set FlowControllerTest.updateFlowFlowFromJsonFromString as flaky
It fails often in CI and as the tested endpoint is deprecated it is not important that the test pass.
2025-10-29 14:12:32 +01:00
Florian Hussonnois
6361a02deb feat(core): add prefill prop to input to allow nullable value (#11819)
Added a new 'prefill' property for all inputs
to specify an optional UI hint for pre-filling the input,while
allowing the input to be nullable.

Fixes: #11819
2025-10-28 14:21:26 +01:00
Florian Hussonnois
78c01999ad feat(triggers): add inputs property to webhook trigger
Add a new `inputs` property to the Webhook trigger, allowing input
data to be passed to the triggered flow. If no inputs are defined on the trigger,
the flow will not receive any inputs, even if some have default values.

This behavior ensures backward compatibility with how the Webhook trigger currently works.
2025-10-27 17:02:03 +01:00
Nicolas K.
893e8c1a49 feat(flows): add human task (#12276)
* feat(flows): add human task

* clean(flows): move models and validation into plugin packages and move validation logic to the task

---------

Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
2025-10-23 11:39:00 +02:00