jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity
8,807 Commits 164 Branches 427 Tags
develop
Commit Graph

2947 Commits

Author SHA1 Message Date
Bhuvan C V
2b224bcde8 test(core): add regression test for illegal namespace updates 
Adds a missing test case to FlowTest.java to verify that Flow.validateUpdate() correctly prevents namespace modification.
 2025-12-10 14:36:00 +01:00
Bikash Agarwala
f626c85346 fix: allow zero-byte file uploads in execution inputs (fixes #8218) 2025-12-09 12:52:25 +01:00
Shankar
56bb3ca29c Fix week format in filter 2025-12-09 10:00:37 +01:00
Loïc Mathieu
14029e8c14 chore(tests): isolate concurrency related tests in their own class 2025-12-09 09:57:49 +01:00
char zheng
bea3d63d89 fix(executions): concurrency limit exceeded for KILLED execution 
Fixes #13211
 2025-12-09 09:57:49 +01:00
Shivansh Sharma
24a3bbd303 11229 : Ensure that a label key cannot contain spaces, special characters or encoded values (e.g. emojis) 2025-12-09 09:32:22 +01:00
Loïc Mathieu
424a6cb41a fix(execution): skip the render cache in flowable for properties used to compute next tasks 
As when the flowable is itself in a flowable that process tasks concurrently like the ForEach when using a concurrency limit, it can be done multiple time with different values.

This can only occurs if the expression is using `taskRun.value`.

Fixes https://github.com/kestra-io/kestra-ee/issues/6055
 2025-12-08 15:03:06 +01:00
luoxin
386d4a15f0 fix(system): enable parallel loading for namespace files. (#13375) 
* perf(core): enable parallel loading for namespace files.

* refactor(core): extract thread count calculation to avoid duplication.

* resolve namespaceFilesWithNamespaces test error.

---------

Co-authored-by: luoxin5 <luoxin5@xiaomi.com>
 2025-12-08 09:23:35 +01:00
Florian Hussonnois
3cbad1ce0d fix(tests): fix StatefulTriggerInterfaceTest 2025-12-05 17:56:32 +01:00
Florian Hussonnois
e440c402b4 fix(flows): add flow variables to runContext for checks 
Related-to: kestra-io/kestra-ee#5759
 2025-12-04 16:13:32 +01:00
yuri1969
4ec7f23a7b Amend inconsistency 2025-12-04 12:20:16 +01:00
yuri1969
107ba16ce3 feat(core): modernize Pebble cache 
* Modernized the LRU cache from Guava to Caffeine.
* Registered metrics.
 2025-12-04 12:20:16 +01:00
brian-mulier-p
3dfa5f97c4 fix(core): deprecate Await util (#13369) 
This reverts commit 9fa94deba9.
 2025-12-04 09:57:12 +01:00
Roman Acevedo
8898ba736b test(executions): fix ES duration tests 2025-12-03 18:37:49 +01:00
Loïc Mathieu
f5665bf719 Update core/src/test/java/io/kestra/core/serializers/YamlParserTest.java 2025-12-03 17:34:52 +01:00
Loïc Mathieu
b6db688003 Update core/src/test/resources/flows/valids/labels-deserialization.yaml 2025-12-03 17:34:52 +01:00
lizi3
93f5e366ed fix: add unit test 2025-12-03 17:34:52 +01:00
lizi3
0465ffa5df fix: unify label deserialization for numeric values in array form 
The START_ARRAY branch did not apply type conversion for label values,
causing Integer/Boolean values to fail during execution state update.
Applying the same allowed-type conversion logic as the START_OBJECT branch
fixes the inconsistency and prevents cast errors.
 2025-12-03 17:34:52 +01:00
François Delbrayelle
a72ecfc2eb chore(icons): remove white backgrounds (#13362) 2025-12-03 15:27:24 +01:00
brian.mulier
9d21ab4b26 fix(cli): don't throw on ns files migration for ns without files 
closes https://github.com/kestra-io/kestra-ee/issues/6019#event-21325612781
 2025-12-03 14:32:30 +01:00
Loïc Mathieu
56fb304ff6 fix(execution): NORMAL kind should also be retrieved 
Fixes #13262
 2025-12-03 11:43:50 +01:00
YannC
393b132444 fix: correct regex when importing flow (#13320) 2025-12-03 09:06:18 +01:00
Loïc Mathieu
d08a2d8930 fix(executions): support Download content dispositions with brackets 
By escaping them with %5B and %5D.

Fixes #13299
 2025-12-02 16:02:02 +01:00
brian-mulier-p
b18e3b76ef refacto(core): expose TaskLogLineMatcher (#13300) 2025-12-02 12:46:47 +01:00
brian.mulier
26f6154eed fix(tests): NOT EQUALS on NamespaceFileMetadataRepositoryTest query was too flaky 2025-12-02 11:46:52 +01:00
Loïc Mathieu
ea44128d2b chore(system): refactor RunnerUtils to be a static utils 
Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
 2025-12-02 10:37:46 +01:00
Loïc Mathieu
4602546045 chore(system): refactor the TaskLogLineMatcher as a standard class 
https://github.com/kestra-io/kestra-ee/issues/4228
 2025-12-02 10:37:16 +01:00
Loïc Mathieu
e1f983cc2d chore(system): refacto TreadMainFactoryBuilder to be a static utility 
Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
 2025-12-02 10:05:20 +01:00
Loïc Mathieu
68f92e1159 chore(executions): replace usage of the DefaultRunContext by supported API 
Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
 2025-12-02 10:04:24 +01:00
brian.mulier
4d353937c3 feat(ns-files): introduce PurgeFiles task 
part of #5617
 2025-12-01 18:13:49 +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
brian.mulier
4e1b53fadf fix(tests): add tenant to ConcurrencyLimitServiceTest 2025-12-01 16:56:01 +01:00
brian.mulier
90c3281eae fix(tests): WorkingDirectoryTest.outputFiles flaky 2025-12-01 16:56:01 +01:00
brian.mulier
9fa94deba9 refacto(core): rename Await.until(sleep) and (timeout) to avoid confusions 2025-12-01 16:56:01 +01:00
Roman Acevedo
7aca309be5 feat(dashboard): calculate running execution duration on the fly 2025-12-01 16:06:35 +01:00
Roman Acevedo
fbe6df34ca feat(executions): set duration to null for non-terminated execs and fix frontend duration 2025-12-01 16:06:35 +01:00
Loïc Mathieu
64a2c3b746 chore(system): add @CheckReturnValue to AclCheck methods to be sure check() is called 2025-12-01 12:45:05 +01:00
brian-mulier-p
f06b1c5347 fix(core): concurrency limit on JDBC was decrementing when using FAIL or CANCEL behavior (#13220) 
closes https://github.com/kestra-io/kestra/issues/13141
 2025-12-01 12:44:30 +01:00
brian-mulier-p
ef154bb029 fix(core): acl.check was not called (#13265) 2025-12-01 12:09:34 +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
Loïc Mathieu
20c5328199 feat(system): deprecate RunContext method that must not be used anymore 
- `isInitialized()` is not used by plugin so should not be part of the interface
- `getApplicationContext` should not be used anymore, all tasks that uses it would be refactored to avoid its usage

Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
 2025-12-01 09:51:12 +01:00
Loïc Mathieu
91330496f2 fix(execution): failed flowable should also have a failed attempt 
When a flowable fail, it should also switch its attempts to FAILED.

Fixes #12614
 2025-12-01 09:50: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
François Delbrayelle
84840fe090 fix(http): safe guard on too big files for Request (#13232) 2025-11-28 13:39:37 +01:00
Loïc Mathieu
b33fbc284d fix(executions): don't ends flowable if any subtasks should be retried 
Fixes #11444
 2025-11-28 11:00:49 +01:00
brian.mulier
d6933b8e49 fix(executions): avoid JdbcExecutor from being stuck due to missing flow 
In tests it can occur for example
 2025-11-27 19:23:17 +01:00
brian.mulier
e37e2b0166 fix(tests): better error message on AbstractRunnerTest.concurrencyQueueRestarted 2025-11-27 19:23:17 +01:00
brian.mulier
9f90412237 fix(tests): run WorkingDirectoryTest in same thread due to race condition 
related to https://github.com/kestra-io/kestra/issues/13134
 2025-11-27 19:23:17 +01:00
brian.mulier
98678deabb fix(tests): use test extension context per classes to follow our concurrent test run strategy 2025-11-27 19:23:17 +01:00
François Delbrayelle
d7caf9ae00 docs: indent properly core plugins examples (#13199) 2025-11-27 11:04:08 +01:00