16 Commits

Author SHA1 Message Date
brian-mulier-p
034eedc69d fix(assets): task-level declared output assets can use current task output in pebble (#14345)
closes https://github.com/kestra-io/kestra-ee/issues/6424
2026-01-29 15:28:49 +01:00
Florian Hussonnois
e0a97d90df refactor(system): re-implement MaintenanceService api
Adds listener pattern for maintenance mode

Changes:
* Adds utility class Disposable
2026-01-15 12:15:49 +01:00
Loïc Mathieu
75d396e5ff fix(test): try to unflaky WorkerTest.killed()
It may not fix the flakiness, if so, the next step would be to mark it as flaky...
2026-01-14 13:35:10 +01:00
yuri
55eb6806bd chore(logs): make start/stop messages clearer 2026-01-05 10:10:48 +01:00
Loïc Mathieu
156a75c668 feat(assets): continue Assets implementation 2025-12-29 17:26:11 +01:00
brian.mulier
9743f7fe56 feat(assets): introduce Assets 2025-12-29 17:26:11 +01:00
Loïc Mathieu
1b74842485 feat(system): replace our SecurityManager by a Java agent
Part-of: https://github.com/kestra-io/kestra-ee/pull/6153
2025-12-29 14:23:22 +01:00
Loïc Mathieu
a960a9f982 feat(plugin): bring cloneForPlugin to the RunContext
To replace the usage of the RunContextInitializer for that as plugins using another plugin needs it.

Part-of: https://github.com/kestra-io/kestra-ee/issues/4228
2025-12-15 09:58:54 +01:00
brian-mulier-p
3dfa5f97c4 fix(core): deprecate Await util (#13369)
This reverts commit 9fa94deba9.
2025-12-04 09:57:12 +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
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
Loïc Mathieu
8f4bafc666 feat(execution): add an attemps on skipped tasks 2025-11-26 18:11:07 +01:00
Loïc Mathieu
9d6694f807 fix(system): WorkerTask should not FAILED when interrupting so they would be resubmitted
When a Worker is stopping, it will first wait for all running tasks to stop, then kill them. For those that didn't implement kill their thread would be interrupted.

But if the task is properly killed, or support interrupts (like the Sleep task), it would ends in FAILED then a WorkerTaskWould be send that would fail the flow preventing the WorkerTask to be resubmitted.

We nows check if the worker is terminating and should resubmit, in this case we didn't emit any WorkerTaskResult

Fixes #13108
Part-of: https://github.com/kestra-io/kestra-ee/issues/5556
2025-11-21 16:58:36 +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
Loïc Mathieu
f3057d2d57 chore(system): extract the worker to its own module 2025-09-04 11:04:13 +02:00