doc(task): improve TemplatedTask example #13768

Ben8t · 2025-12-19T13:07:18Z

No description provided.

github-actions · 2025-12-19T13:12:13Z

🐋 Docker image

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

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:13768 server local

🧪 Java Unit Tests

	Tests	Passed ☑️	Skipped ⚠️	Failed ❌️	Time ⏱
Java Tests Report	3631 ran	3617 ✅	12 ⚠️	2 ❌	33m 4s 782ms

Test	Result	Time ⏱
Java Tests Report
ExecutionControllerRunnerTest.searchExecutions()	❌ failure	283ms
FlowControllerTest.importFlowsWithZip()	❌ failure	1s 29ms

github-actions · 2025-12-19T13:29:40Z

Tests report quick summary:

failed ❌ > tests: 3631, success: 3617, skipped: 12, failed: 2

Project	Status	Success	Failed
cli	success ✅	79	0
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	failed ❌	366	2
worker	success ✅	5	0

Failed tests:

webserver > io.kestra.webserver.controllers.api.ExecutionControllerRunnerTest > searchExecutions() failed ❌ in 0.283

org.opentest4j.AssertionFailedError: Expected io.micronaut.http.client.exceptions.HttpClientResponseException to be thrown, but nothing was thrown.

org.opentest4j.AssertionFailedError: Expected io.micronaut.http.client.exceptions.HttpClientResponseException to be thrown, but nothing was thrown.
	at app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:152)
	at app//org.junit.jupiter.api.AssertThrows.assertThrows(AssertThrows.java:73)
	at app//org.junit.jupiter.api.AssertThrows.assertThrows(AssertThrows.java:35)
	at app//org.junit.jupiter.api.Assertions.assertThrows(Assertions.java:3128)
	at app//io.kestra.webserver.controllers.api.ExecutionControllerRunnerTest.searchExecutions(ExecutionControllerRunnerTest.java:1424)
	at [email protected]/java.lang.reflect.Method.invoke(Method.java:580)
	at app//io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:154)
	at app//io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:171)
	at app//io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:128)
	at app//io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:141)
	at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1596)
	at [email protected]/java.util.ArrayList.forEach(ArrayList.java:1596)

webserver > io.kestra.webserver.controllers.api.FlowControllerTest > importFlowsWithZip() failed ❌ in 1.029

io.micronaut.http.client.exceptions.HttpClientResponseException: Client '/': Bad Request

io.micronaut.http.client.exceptions.HttpClientResponseException: Client '/': Bad Request
	at app//io.micronaut.http.client.netty.DefaultHttpClient.makeErrorFromRequestBody(DefaultHttpClient.java:2135)
	at app//io.micronaut.http.client.netty.DefaultHttpClient.handleExchangeResponse(DefaultHttpClient.java:951)
	at app//io.micronaut.http.client.netty.DefaultHttpClient.lambda$exchange$9(DefaultHttpClient.java:904)
	at app//io.micronaut.core.execution.ImperativeExecutionFlowImpl.flatMap(ImperativeExecutionFlowImpl.java:72)
	at app//io.micronaut.http.client.netty.DefaultHttpClient.lambda$exchange$10(DefaultHttpClient.java:904)
	at app//io.micronaut.http.client.netty.DefaultHttpClient.lambda$sendRequestWithRedirectsNoFilter$44(DefaultHttpClient.java:1661)
	at app//io.micronaut.core.execution.ImperativeExecutionFlowImpl.flatMap(ImperativeExecutionFlowImpl.java:72)
	at app//io.micronaut.core.execution.DelayedExecutionFlowImpl$FlatMap.apply(DelayedExecutionFlowImpl.java:359)
	at app//io.micronaut.core.execution.DelayedExecutionFlowImpl.work(DelayedExecutionFlowImpl.java:58)
	at app//io.micronaut.core.execution.DelayedExecutionFlowImpl.completeLazy(DelayedExecutionFlowImpl.java:80)
	at app//io.micronaut.core.execution.DelayedExecutionFlowImpl.complete(DelayedExecutionFlowImpl.java:99)
	at app//io.micronaut.http.client.netty.DefaultHttpClient$6.complete(DefaultHttpClient.java:1758)
	at app//io.micronaut.http.client.netty.Http1ResponseHandler$BufferedContent.complete(Http1ResponseHandler.java:226)
	at app//io.micronaut.http.client.netty.Http1ResponseHandler$BufferedContent.read(Http1ResponseHandler.java:187)
	at app//io.micronaut.http.client.netty.Http1ResponseHandler$BufferedContent.read(Http1ResponseHandler.java:161)
	at app//io.micronaut.http.client.netty.Http1ResponseHandler.channelReadInstrumented(Http1ResponseHandler.java:75)
	at app//io.micronaut.http.client.netty.Http1ResponseHandler.channelReadInstrumented(Http1ResponseHandler.java:50)
	at app//io.micronaut.http.client.netty.SimpleChannelInboundHandlerInstrumented.channelRead0(SimpleChannelInboundHandlerInstrumented.java:46)
	at app//io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
	at app//io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:356)
	at app//io.netty.handler.codec.http.HttpContentDecoder.decode(HttpContentDecoder.java:170)
	at app//io.netty.handler.codec.http.HttpContentDecoder.decode(HttpContentDecoder.java:48)
	at app//io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:91)
	at app//io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:356)
	at app//io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:434)
	at app//io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:361)
	at app//io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:325)
	at app//io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:249)
	at app//io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:354)
	at app//io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:293)
	at app//io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:354)
	at app//io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1429)
	at app//io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918)
	at app//io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:172)
	at app//io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:445)
	at app//io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:388)
	at app//io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:596)
	at app//io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:571)
	at app//io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:512)
	at app//io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:484)
	at app//io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
	at app//io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)
	at app//io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1195)
	at app//io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at app//io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at [email protected]/java.lang.Thread.run(Thread.java:1583)
	Suppressed: java.lang.Exception: #block terminated with an error
		at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
		at reactor.core.publisher.Mono.block(Mono.java:1779)
		at io.micronaut.http.client.netty.DefaultHttpClient$1.exchange(DefaultHttpClient.java:603)
		at io.micronaut.http.client.BlockingHttpClient.exchange(BlockingHttpClient.java:78)
		at io.micronaut.http.client.BlockingHttpClient.exchange(BlockingHttpClient.java:92)
		at io.kestra.webserver.controllers.api.FlowControllerTest.importFlowsWithZip(FlowControllerTest.java:698)
		at java.base/java.lang.reflect.Method.invoke(Method.java:580)
		at io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:154)
		at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:171)
		at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:128)
		at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:141)
		at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
		at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

Flaky tests report quick summary:

failed ❌ > tests: 150, success: 145, skipped: 2, failed: 3

Project	Status	Success	Failed
cli	success ✅	2	0
core	success ✅	5	0
jdbc	success ✅	2	0
jdbc-h2	failed ❌	42	2
jdbc-mysql	failed ❌	45	1
jdbc-postgres	success ✅	46	0
scheduler	success ✅	2	0
script	success ✅	1	0
webserver	success ✅	2	0

Failed tests:

jdbc-h2 > io.kestra.runner.h2.H2RunnerConcurrencyTest > flowConcurrencyQueueKilled() failed ❌ in 40.560

java.lang.RuntimeException: Execution 2zviWuf31rHaQhVwjQJeID is currently at the status RUNNING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-queue-killed","id":"2zviWuf31rHaQhVwjQJeID","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"5KpZ2v4oJ1ICuW0YuuS7XX","executionId":"2zviWuf31rHaQhVwjQJeID","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.983861Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.983863Z"}],"startDate":"2025-12-19T13:20:07.983861Z","durationOrComputeIt":40.250154433},"workerId":"f8045f09-e718-4f87-9d53-8d5df81787b8"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.918421Z"},{"state":"SUBMITTED","date":"2025-12-19T13:20:07.956137Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.981928Z"}],"startDate":"2025-12-19T13:20:07.918421Z","durationOrComputeIt":40.315705499}}],"labels":[{"key":"system.correlationId","value":"2zviWuf31rHaQhVwjQJeID"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.882654Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.924240Z"}],"startDate":"2025-12-19T13:20:07.882654Z","durationOrComputeIt":40.351555975},"originalId":"2zviWuf31rHaQhVwjQJeID","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:20:07.882659Z"}}

java.lang.RuntimeException: Execution 2zviWuf31rHaQhVwjQJeID is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"2zviWuf31rHaQhVwjQJeID","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"5KpZ2v4oJ1ICuW0YuuS7XX","executionId":"2zviWuf31rHaQhVwjQJeID","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.983861Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.983863Z"}],"startDate":"2025-12-19T13:20:07.983861Z","durationOrComputeIt":40.250154433},"workerId":"f8045f09-e718-4f87-9d53-8d5df81787b8"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.918421Z"},{"state":"SUBMITTED","date":"2025-12-19T13:20:07.956137Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.981928Z"}],"startDate":"2025-12-19T13:20:07.918421Z","durationOrComputeIt":40.315705499}}],"labels":[{"key":"system.correlationId","value":"2zviWuf31rHaQhVwjQJeID"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:07.882654Z"},{"state":"RUNNING","date":"2025-12-19T13:20:07.924240Z"}],"startDate":"2025-12-19T13:20:07.882654Z","durationOrComputeIt":40.351555975},"originalId":"2zviWuf31rHaQhVwjQJeID","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:20:07.882659Z"}}
	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:154)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:171)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:128)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:141)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

jdbc-h2 > io.kestra.runner.h2.H2RunnerConcurrencyTest > flowConcurrencyParallelSubflowKill() failed ❌ in 21.047

java.lang.RuntimeException: Execution 4ZRvmvle2xKOSb7TFA7P2D is currently at the status RUNNING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"4ZRvmvle2xKOSb7TFA7P2D","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"22pLzzDRyy6SQkTCKPkyCS","executionId":"4ZRvmvle2xKOSb7TFA7P2D","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:00.113901Z"},{"state":"RUNNING","date":"2025-12-19T13:21:00.197956Z"}],"startDate":"2025-12-19T13:21:00.113901Z","durationOrComputeIt":9.142878822}}],"labels":[{"key":"system.correlationId","value":"1UyC1S0ovg7kIC9btfcOn8"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:49.084898Z"},{"state":"QUEUED","date":"2025-12-19T13:20:49.242399Z"},{"state":"RUNNING","date":"2025-12-19T13:20:59.989647Z"}],"startDate":"2025-12-19T13:20:49.084898Z","durationOrComputeIt":20.172206907},"originalId":"4ZRvmvle2xKOSb7TFA7P2D","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"taskId":"flow2","flowRevision":1,"namespace":"io.kestra.tests","executionId":"1UyC1S0ovg7kIC9btfcOn8","taskRunId":"3M7X0z5clLiYNMmbotogEY","flowId":"flow-concurrency-parallel-subflow-kill"}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:20:49.084903Z"}}

java.lang.RuntimeException: Execution 4ZRvmvle2xKOSb7TFA7P2D is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"4ZRvmvle2xKOSb7TFA7P2D","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"22pLzzDRyy6SQkTCKPkyCS","executionId":"4ZRvmvle2xKOSb7TFA7P2D","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:00.113901Z"},{"state":"RUNNING","date":"2025-12-19T13:21:00.197956Z"}],"startDate":"2025-12-19T13:21:00.113901Z","durationOrComputeIt":9.142878822}}],"labels":[{"key":"system.correlationId","value":"1UyC1S0ovg7kIC9btfcOn8"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:20:49.084898Z"},{"state":"QUEUED","date":"2025-12-19T13:20:49.242399Z"},{"state":"RUNNING","date":"2025-12-19T13:20:59.989647Z"}],"startDate":"2025-12-19T13:20:49.084898Z","durationOrComputeIt":20.172206907},"originalId":"4ZRvmvle2xKOSb7TFA7P2D","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"taskId":"flow2","flowRevision":1,"namespace":"io.kestra.tests","executionId":"1UyC1S0ovg7kIC9btfcOn8","taskRunId":"3M7X0z5clLiYNMmbotogEY","flowId":"flow-concurrency-parallel-subflow-kill"}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:20:49.084903Z"}}
	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:154)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:171)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:128)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:141)
	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.372

java.lang.RuntimeException: Execution 4LQQWnXzOwHCliZDqiShbR is currently at the status RUNNING which is not the awaited one, full execution object:&#10;{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"4LQQWnXzOwHCliZDqiShbR","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"7UgZ4UgLwHjFxa1t8UIViJ","executionId":"4LQQWnXzOwHCliZDqiShbR","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:17.763767Z"},{"state":"RUNNING","date":"2025-12-19T13:21:17.844018Z"}],"startDate":"2025-12-19T13:21:17.763767Z","durationOrComputeIt":9.338822975}}],"labels":[{"key":"system.correlationId","value":"4won30PwjRWtRWwuW6fN4b"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:06.874940Z"},{"state":"QUEUED","date":"2025-12-19T13:21:06.982535Z"},{"state":"RUNNING","date":"2025-12-19T13:21:17.714348Z"}],"startDate":"2025-12-19T13:21:06.874940Z","durationOrComputeIt":20.228511047},"originalId":"4LQQWnXzOwHCliZDqiShbR","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow2","namespace":"io.kestra.tests","taskRunId":"PiGwncm8n1NwbNs2c2wBW","executionId":"4won30PwjRWtRWwuW6fN4b","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:21:06.874945Z"}}

java.lang.RuntimeException: Execution 4LQQWnXzOwHCliZDqiShbR is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"4LQQWnXzOwHCliZDqiShbR","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"7UgZ4UgLwHjFxa1t8UIViJ","executionId":"4LQQWnXzOwHCliZDqiShbR","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","taskId":"flow1","outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:17.763767Z"},{"state":"RUNNING","date":"2025-12-19T13:21:17.844018Z"}],"startDate":"2025-12-19T13:21:17.763767Z","durationOrComputeIt":9.338822975}}],"labels":[{"key":"system.correlationId","value":"4won30PwjRWtRWwuW6fN4b"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:21:06.874940Z"},{"state":"QUEUED","date":"2025-12-19T13:21:06.982535Z"},{"state":"RUNNING","date":"2025-12-19T13:21:17.714348Z"}],"startDate":"2025-12-19T13:21:06.874940Z","durationOrComputeIt":20.228511047},"originalId":"4LQQWnXzOwHCliZDqiShbR","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow2","namespace":"io.kestra.tests","taskRunId":"PiGwncm8n1NwbNs2c2wBW","executionId":"4won30PwjRWtRWwuW6fN4b","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:21:06.874945Z"}}
	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:154)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:171)
	at io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:128)
	at io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:141)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

doc(task): improve TemplatedTask example

0a121c6

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

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

Ben8t requested a review from fdelbrayelle December 19, 2025 13:07

fdelbrayelle approved these changes Dec 19, 2025

View reviewed changes

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

doc(task): improve TemplatedTask example #13768

doc(task): improve TemplatedTask example #13768

Uh oh!

Ben8t commented Dec 19, 2025

Uh oh!

github-actions bot commented Dec 19, 2025 •

edited

Loading

Uh oh!

github-actions bot commented Dec 19, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

doc(task): improve TemplatedTask example #13768

Are you sure you want to change the base?

doc(task): improve TemplatedTask example #13768

Uh oh!

Conversation

Ben8t commented Dec 19, 2025

Uh oh!

github-actions bot commented Dec 19, 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 19, 2025

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 19, 2025 •

edited

Loading