feat(system): replace our SecurityManager by a Java agent #13731

loicmathieu · 2025-12-17T11:54:21Z

Part-of: https://github.com/kestra-io/kestra-ee/pull/6153

github-actions · 2025-12-17T11:58:26Z

🐋 Docker image

ghcr.io/kestra-io/kestra-pr:13731

docker run --pull=always --rm -it -p 8080:8080 --user=root -v /var/run/docker.sock:/var/run/docker.sock -v /tmp:/tmp ghcr.io/kestra-io/kestra-pr:13731 server local

🧪 Java Unit Tests

	Tests	Passed ☑️	Skipped ⚠️	Failed ❌️	Time ⏱
Java Tests Report	3631 ran	3618 ✅	12 ⚠️	1 ❌	32m 59s 416ms

Test	Result	Time ⏱
Java Tests Report
PluginDocCommandTest.run()	❌ failure	14s 889ms

github-actions · 2025-12-17T12:12:18Z

Tests report quick summary:

failed ❌ > tests: 3631, success: 3618, skipped: 12, failed: 1

Project	Status	Success	Failed
cli	failed ❌	78	1
core	success ✅	1687	0
executor	success ✅	4	0
jdbc	success ✅	10	0
jdbc-h2	success ✅	455	0
jdbc-mysql	success ✅	458	0
jdbc-postgres	success ✅	458	0
processor	success ✅	7	0
runner-memory	success ✅	1	0
scheduler	success ✅	24	0
script	success ✅	11	0
storage-local	success ✅	64	0
webserver	success ✅	368	0
worker	success ✅	5	0

Failed tests:

cli > io.kestra.cli.commands.plugins.PluginDocCommandTest > run() failed ❌ in 14.889

org.opentest4j.AssertionFailedError: &#10;expected: 1&#10; but was: 2

org.opentest4j.AssertionFailedError: 
expected: 1
 but was: 2
	at app//io.kestra.cli.commands.plugins.PluginDocCommandTest.run(PluginDocCommandTest.java:46)
	at [email protected]/java.lang.reflect.Method.invoke(Method.java:580)
	at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1596)
	at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1596)

Flaky tests report quick summary:

failed ❌ > tests: 150, success: 142, skipped: 2, failed: 6

Project	Status	Success	Failed
cli	success ✅	2	0
core	success ✅	5	0
jdbc	success ✅	2	0
jdbc-h2	success ✅	44	0
jdbc-mysql	failed ❌	43	3
jdbc-postgres	failed ❌	43	3
scheduler	success ✅	2	0
script	success ✅	1	0
webserver	success ✅	2	0

Failed tests:

jdbc-mysql > io.kestra.repository.mysql.MysqlExecutionRepositoryTest > [1] filter=QueryFilter[field=QUERY, operation=EQUALS, value=unittest], expectedSize=29 failed ❌ in 11.394

java.lang.AssertionError: &#10;Expected size: 29 but was: 0 in:&#10;[]

java.lang.AssertionError: 
Expected size: 29 but was: 0 in:
[]
	at io.kestra.core.repositories.AbstractExecutionRepositoryTest.should_find_all(AbstractExecutionRepositoryTest.java:193)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$3.proceed(MicronautJunit5Extension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension$3.proceed(AbstractMicronautExtension.java:174)
	at io.micronaut.test.context.TestMethodInterceptor.interceptTest(TestMethodInterceptor.java:46)
	at io.micronaut.transaction.test.DefaultTestTransactionExecutionListener.lambda$interceptTest$0(DefaultTestTransactionExecutionListener.java:93)
	at io.micronaut.transaction.support.AbstractPropagatedStatusTransactionOperations.lambda$execute$2(AbstractPropagatedStatusTransactionOperations.java:68)
	at io.micronaut.transaction.TransactionCallback.apply(TransactionCallback.java:37)
	at io.micronaut.transaction.support.AbstractTransactionOperations.executeTransactional(AbstractTransactionOperations.java:333)
	at io.micronaut.transaction.support.AbstractTransactionOperations.executeWithNewTransaction(AbstractTransactionOperations.java:318)
	at io.micronaut.transaction.support.AbstractTransactionOperations.executeNew(AbstractTransactionOperations.java:235)
	at io.micronaut.transaction.support.AbstractTransactionOperations.doExecute(AbstractTransactionOperations.java:137)
	at io.micronaut.transaction.support.AbstractTransactionOperations.lambda$doExecute$0(AbstractTransactionOperations.java:122)
	at io.micronaut.data.connection.support.AbstractConnectionOperations.executeWithNewConnection(AbstractConnectionOperations.java:167)
	at io.micronaut.data.connection.support.AbstractConnectionOperations.execute(AbstractConnectionOperations.java:114)
	at io.micronaut.transaction.support.AbstractTransactionOperations.doExecute(AbstractTransactionOperations.java:120)
	at io.micronaut.transaction.support.AbstractPropagatedStatusTransactionOperations.execute(AbstractPropagatedStatusTransactionOperations.java:65)
	at io.micronaut.transaction.test.DefaultTestTransactionExecutionListener.interceptTest(DefaultTestTransactionExecutionListener.java:91)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:166)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestTemplateMethod(MicronautJunit5Extension.java:149)
	at java.base/java.util.Optional.ifPresent(Optional.java:178)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:1024)
	at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:1024)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:276)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-mysql > io.kestra.runner.mysql.MysqlRunnerConcurrencyTest > flowConcurrencyQueueKilled() failed ❌ in 41.097

java.lang.RuntimeException: Execution 101UyumSbHmHXKH2Aiz8nD is currently at the status RUNNING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-queue-killed","id":"101UyumSbHmHXKH2Aiz8nD","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"fkRqDqc5UPlMgCxkWnfJ4","executionId":"101UyumSbHmHXKH2Aiz8nD","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:55.129692Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.129695Z"}],"startDate":"2025-12-23T11:39:55.129692Z","durationOrComputeIt":40.532379358},"workerId":"5844301c-e9f3-4c52-b242-875ba076a6ab"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:55.000573Z"},{"state":"SUBMITTED","date":"2025-12-23T11:39:55.072408Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.124020Z"}],"startDate":"2025-12-23T11:39:55.000573Z","durationOrComputeIt":40.661626959}}],"labels":[{"key":"system.correlationId","value":"101UyumSbHmHXKH2Aiz8nD"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:54.901549Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.003575Z"}],"startDate":"2025-12-23T11:39:54.901549Z","durationOrComputeIt":40.760729236},"originalId":"101UyumSbHmHXKH2Aiz8nD","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:39:54.901554Z"}}

java.lang.RuntimeException: Execution 101UyumSbHmHXKH2Aiz8nD is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"101UyumSbHmHXKH2Aiz8nD","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"fkRqDqc5UPlMgCxkWnfJ4","executionId":"101UyumSbHmHXKH2Aiz8nD","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:55.129692Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.129695Z"}],"startDate":"2025-12-23T11:39:55.129692Z","durationOrComputeIt":40.532379358},"workerId":"5844301c-e9f3-4c52-b242-875ba076a6ab"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:55.000573Z"},{"state":"SUBMITTED","date":"2025-12-23T11:39:55.072408Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.124020Z"}],"startDate":"2025-12-23T11:39:55.000573Z","durationOrComputeIt":40.661626959}}],"labels":[{"key":"system.correlationId","value":"101UyumSbHmHXKH2Aiz8nD"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:39:54.901549Z"},{"state":"RUNNING","date":"2025-12-23T11:39:55.003575Z"}],"startDate":"2025-12-23T11:39:54.901549Z","durationOrComputeIt":40.760729236},"originalId":"101UyumSbHmHXKH2Aiz8nD","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:39:54.901554Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:218)
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:197)
	at io.kestra.core.runners.TestRunnerUtils.killExecution(TestRunnerUtils.java:318)
	at io.kestra.core.runners.FlowConcurrencyCaseTest.flowConcurrencyQueueKilled(FlowConcurrencyCaseTest.java:325)
	at io.kestra.core.runners.AbstractRunnerConcurrencyTest.flowConcurrencyQueueKilled(AbstractRunnerConcurrencyTest.java:91)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-mysql > io.kestra.runner.mysql.MysqlRunnerConcurrencyTest > flowConcurrencyParallelSubflowKill() failed ❌ in 21.299

java.lang.RuntimeException: Execution 6b7sBZZBxFrAgrBB0GWPk0 is currently at the status RUNNING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"6b7sBZZBxFrAgrBB0GWPk0","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"2QlQvpRX3sHdQnUPOgAOeL","executionId":"6b7sBZZBxFrAgrBB0GWPk0","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:47.574747Z"},{"state":"RUNNING","date":"2025-12-23T11:40:47.634261Z"}],"startDate":"2025-12-23T11:40:47.574747Z","durationOrComputeIt":9.265158852}}],"labels":[{"key":"system.correlationId","value":"Ri6WnxhQU0Um8TogZKKiV"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:36.604800Z"},{"state":"QUEUED","date":"2025-12-23T11:40:36.752364Z"},{"state":"RUNNING","date":"2025-12-23T11:40:47.534719Z"}],"startDate":"2025-12-23T11:40:36.604800Z","durationOrComputeIt":20.235275310},"originalId":"6b7sBZZBxFrAgrBB0GWPk0","trigger":{"id":"flow1","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow1","namespace":"io.kestra.tests","taskRunId":"ythw6uNtGpKY4VbB55toZ","executionId":"Ri6WnxhQU0Um8TogZKKiV","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:36.604805Z"}}

java.lang.RuntimeException: Execution 6b7sBZZBxFrAgrBB0GWPk0 is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"6b7sBZZBxFrAgrBB0GWPk0","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"2QlQvpRX3sHdQnUPOgAOeL","executionId":"6b7sBZZBxFrAgrBB0GWPk0","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:47.574747Z"},{"state":"RUNNING","date":"2025-12-23T11:40:47.634261Z"}],"startDate":"2025-12-23T11:40:47.574747Z","durationOrComputeIt":9.265158852}}],"labels":[{"key":"system.correlationId","value":"Ri6WnxhQU0Um8TogZKKiV"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:36.604800Z"},{"state":"QUEUED","date":"2025-12-23T11:40:36.752364Z"},{"state":"RUNNING","date":"2025-12-23T11:40:47.534719Z"}],"startDate":"2025-12-23T11:40:36.604800Z","durationOrComputeIt":20.235275310},"originalId":"6b7sBZZBxFrAgrBB0GWPk0","trigger":{"id":"flow1","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow1","namespace":"io.kestra.tests","taskRunId":"ythw6uNtGpKY4VbB55toZ","executionId":"Ri6WnxhQU0Um8TogZKKiV","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:36.604805Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:218)
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:197)
	at io.kestra.core.runners.FlowConcurrencyCaseTest.flowConcurrencyParallelSubflowKill(FlowConcurrencyCaseTest.java:241)
	at io.kestra.core.runners.AbstractRunnerConcurrencyTest.flowConcurrencyParallelSubflowKill(AbstractRunnerConcurrencyTest.java:77)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyKilled() failed ❌ in 24.158

java.lang.RuntimeException: Execution 6nWpLDQAg3p7GoIcJOvgxk is currently at the status KILLING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-killed","id":"6nWpLDQAg3p7GoIcJOvgxk","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"6nWpLDQAg3p7GoIcJOvgxk"}],"state":{"current":"KILLING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:27.351971Z"},{"state":"QUEUED","date":"2025-12-23T11:40:27.441201Z"},{"state":"KILLING","date":"2025-12-23T11:40:29.202690Z"}],"startDate":"2025-12-23T11:40:27.351971Z","durationOrComputeIt":20.892982694},"originalId":"6nWpLDQAg3p7GoIcJOvgxk","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:27.351977Z"}}

java.lang.RuntimeException: Execution 6nWpLDQAg3p7GoIcJOvgxk is currently at the status KILLING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-killed","id":"6nWpLDQAg3p7GoIcJOvgxk","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"6nWpLDQAg3p7GoIcJOvgxk"}],"state":{"current":"KILLING","histories":[{"state":"CREATED","date":"2025-12-23T11:40:27.351971Z"},{"state":"QUEUED","date":"2025-12-23T11:40:27.441201Z"},{"state":"KILLING","date":"2025-12-23T11:40:29.202690Z"}],"startDate":"2025-12-23T11:40:27.351971Z","durationOrComputeIt":20.892982694},"originalId":"6nWpLDQAg3p7GoIcJOvgxk","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:27.351977Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:218)
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:197)
	at io.kestra.core.runners.TestRunnerUtils.killExecution(TestRunnerUtils.java:318)
	at io.kestra.core.runners.FlowConcurrencyCaseTest.flowConcurrencyKilled(FlowConcurrencyCaseTest.java:285)
	at io.kestra.core.runners.AbstractRunnerConcurrencyTest.flowConcurrencyKilled(AbstractRunnerConcurrencyTest.java:84)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyQueueKilled() failed ❌ in 30.159

java.lang.RuntimeException: Execution 3AeRvEMOepfLYZcOM8DmK4 is currently at the status CREATED which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-queue-killed","id":"3AeRvEMOepfLYZcOM8DmK4","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3AeRvEMOepfLYZcOM8DmK4"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-23T11:40:48.674796Z"}],"startDate":"2025-12-23T11:40:48.674796Z","durationOrComputeIt":30.017399611},"originalId":"3AeRvEMOepfLYZcOM8DmK4","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:48.674802Z"}}

java.lang.RuntimeException: Execution 3AeRvEMOepfLYZcOM8DmK4 is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"3AeRvEMOepfLYZcOM8DmK4","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3AeRvEMOepfLYZcOM8DmK4"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-23T11:40:48.674796Z"}],"startDate":"2025-12-23T11:40:48.674796Z","durationOrComputeIt":30.017399611},"originalId":"3AeRvEMOepfLYZcOM8DmK4","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:40:48.674802Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:218)
	at io.kestra.core.runners.TestRunnerUtils.emitAndAwaitExecution(TestRunnerUtils.java:193)
	at io.kestra.core.runners.TestRunnerUtils.runOneUntilRunning(TestRunnerUtils.java:169)
	at io.kestra.core.runners.TestRunnerUtils.runOneUntilRunning(TestRunnerUtils.java:152)
	at io.kestra.core.runners.FlowConcurrencyCaseTest.flowConcurrencyQueueKilled(FlowConcurrencyCaseTest.java:296)
	at io.kestra.core.runners.AbstractRunnerConcurrencyTest.flowConcurrencyQueueKilled(AbstractRunnerConcurrencyTest.java:91)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyParallelSubflowKill() failed ❌ in 30.470

java.lang.RuntimeException: Execution 7hHt3DObX93utdBiLwuaTa is currently at the status CREATED which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"7hHt3DObX93utdBiLwuaTa","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill","flowRevision":1,"labels":[{"key":"system.correlationId","value":"7hHt3DObX93utdBiLwuaTa"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-23T11:41:19.184750Z"}],"startDate":"2025-12-23T11:41:19.184750Z","durationOrComputeIt":30.008031621},"originalId":"7hHt3DObX93utdBiLwuaTa","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:41:19.184756Z"}}

java.lang.RuntimeException: Execution 7hHt3DObX93utdBiLwuaTa is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"7hHt3DObX93utdBiLwuaTa","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill","flowRevision":1,"labels":[{"key":"system.correlationId","value":"7hHt3DObX93utdBiLwuaTa"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-23T11:41:19.184750Z"}],"startDate":"2025-12-23T11:41:19.184750Z","durationOrComputeIt":30.008031621},"originalId":"7hHt3DObX93utdBiLwuaTa","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-23T11:41:19.184756Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:218)
	at io.kestra.core.runners.TestRunnerUtils.emitAndAwaitExecution(TestRunnerUtils.java:193)
	at io.kestra.core.runners.TestRunnerUtils.runOneUntilRunning(TestRunnerUtils.java:169)
	at io.kestra.core.runners.TestRunnerUtils.runOneUntilRunning(TestRunnerUtils.java:152)
	at io.kestra.core.runners.FlowConcurrencyCaseTest.flowConcurrencyParallelSubflowKill(FlowConcurrencyCaseTest.java:228)
	at io.kestra.core.runners.AbstractRunnerConcurrencyTest.flowConcurrencyParallelSubflowKill(AbstractRunnerConcurrencyTest.java:77)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Part-of: kestra-io/kestra-ee#6153

github-project-automation bot added this to Pull Requests Dec 17, 2025

github-project-automation bot moved this to To review in Pull Requests Dec 17, 2025

loicmathieu requested a review from fhussonnois December 17, 2025 11:54

fhussonnois approved these changes Dec 17, 2025

View reviewed changes

loicmathieu force-pushed the feat/agent-prototype branch from c11e19a to 541f0fd Compare December 19, 2025 13:20

feat(system): replace our SecurityManager by a Java agent

ce3837b

Part-of: kestra-io/kestra-ee#6153

loicmathieu force-pushed the feat/agent-prototype branch from 541f0fd to ce3837b Compare December 23, 2025 11:15

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat(system): replace our SecurityManager by a Java agent #13731

feat(system): replace our SecurityManager by a Java agent #13731

Uh oh!

loicmathieu commented Dec 17, 2025

Uh oh!

github-actions bot commented Dec 17, 2025 •

edited

Loading

Uh oh!

github-actions bot commented Dec 17, 2025 •

edited

Loading

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

feat(system): replace our SecurityManager by a Java agent #13731

Are you sure you want to change the base?

feat(system): replace our SecurityManager by a Java agent #13731

Uh oh!

Conversation

loicmathieu commented Dec 17, 2025

Uh oh!

github-actions bot commented Dec 17, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

🐋 Docker image

🧪 Java Unit Tests

Uh oh!

github-actions bot commented Dec 17, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Tests report quick summary:

Failed tests:

Flaky tests report quick summary:

Failed tests:

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

github-actions bot commented Dec 17, 2025 •

edited

Loading

github-actions bot commented Dec 17, 2025 •

edited

Loading