Skip to content

Conversation

@elevatebart
Copy link
Contributor

@github-actions
Copy link
Contributor

github-actions bot commented Dec 19, 2025

🐋 Docker image

ghcr.io/kestra-io/kestra-pr:13770
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:13770 server local

🧪 Java Unit Tests

TestsPassed ☑️Skipped ⚠️Failed ❌️Time ⏱
Java Tests Report3632 ran3617 ✅13 ⚠️2 ❌32m 58s 583ms
TestResultTime ⏱
Java Tests Report
ExecutionControllerRunnerTest.searchExecutions()❌ failure778ms
FlowControllerTest.importFlowsWithZip()❌ failure953ms

@github-actions
Copy link
Contributor

Tests report quick summary:

failed ❌ > tests: 3632, success: 3617, skipped: 13, failed: 2

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

Failed tests:

webserver > io.kestra.webserver.controllers.api.ExecutionControllerRunnerTest > searchExecutions() failed ❌ in 0.778
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 0.953
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: 141, skipped: 2, failed: 7

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

Failed tests:

jdbc-h2 > io.kestra.runner.h2.H2RunnerConcurrencyTest > flowConcurrencyQueueKilled() failed ❌ in 40.471
java.lang.RuntimeException: Execution 4eGgnmJ3zYBSj9WtFl5qet is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"4eGgnmJ3zYBSj9WtFl5qet","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"557KIeL7WItKHKr7jqwwsS","executionId":"4eGgnmJ3zYBSj9WtFl5qet","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.079252Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.079253Z"}],"durationOrComputeIt":40.260859484,"startDate":"2025-12-19T13:45:39.079252Z"},"workerId":"3280db80-1316-4efe-9d30-ca080d1a55cf"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.040300Z"},{"state":"SUBMITTED","date":"2025-12-19T13:45:39.055617Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.078907Z"}],"durationOrComputeIt":40.299980179,"startDate":"2025-12-19T13:45:39.040300Z"}}],"labels":[{"key":"system.correlationId","value":"4eGgnmJ3zYBSj9WtFl5qet"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.017911Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.041540Z"}],"durationOrComputeIt":40.322495454,"startDate":"2025-12-19T13:45:39.017911Z"},"originalId":"4eGgnmJ3zYBSj9WtFl5qet","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:45:39.017915Z"}}

java.lang.RuntimeException: Execution 4eGgnmJ3zYBSj9WtFl5qet is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"4eGgnmJ3zYBSj9WtFl5qet","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-queue-killed","id":"557KIeL7WItKHKr7jqwwsS","executionId":"4eGgnmJ3zYBSj9WtFl5qet","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","taskId":"sleep","attempts":[{"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.079252Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.079253Z"}],"durationOrComputeIt":40.260859484,"startDate":"2025-12-19T13:45:39.079252Z"},"workerId":"3280db80-1316-4efe-9d30-ca080d1a55cf"}],"outputs":null,"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.040300Z"},{"state":"SUBMITTED","date":"2025-12-19T13:45:39.055617Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.078907Z"}],"durationOrComputeIt":40.299980179,"startDate":"2025-12-19T13:45:39.040300Z"}}],"labels":[{"key":"system.correlationId","value":"4eGgnmJ3zYBSj9WtFl5qet"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:45:39.017911Z"},{"state":"RUNNING","date":"2025-12-19T13:45:39.041540Z"}],"durationOrComputeIt":40.322495454,"startDate":"2025-12-19T13:45:39.017911Z"},"originalId":"4eGgnmJ3zYBSj9WtFl5qet","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:45:39.017915Z"}}
	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.147
java.lang.RuntimeException: Execution 6sXcTVrDUskytbHfUuIg7c is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"6sXcTVrDUskytbHfUuIg7c","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3qUmUNmE1fhALBkTfmpuOz","executionId":"6sXcTVrDUskytbHfUuIg7c","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:46:30.919094Z"},{"state":"RUNNING","date":"2025-12-19T13:46:30.981669Z"}],"durationOrComputeIt":9.335822585,"startDate":"2025-12-19T13:46:30.919094Z"}}],"labels":[{"key":"system.correlationId","value":"5hje19siWdKFE3ORYtsO5P"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:46:20.037635Z"},{"state":"QUEUED","date":"2025-12-19T13:46:20.194976Z"},{"state":"RUNNING","date":"2025-12-19T13:46:30.882752Z"}],"durationOrComputeIt":20.217573871,"startDate":"2025-12-19T13:46:20.037635Z"},"originalId":"6sXcTVrDUskytbHfUuIg7c","trigger":{"id":"flow1","type":"io.kestra.plugin.core.flow.Subflow","variables":{"taskId":"flow1","flowRevision":1,"namespace":"io.kestra.tests","executionId":"5hje19siWdKFE3ORYtsO5P","taskRunId":"Xs83yPgdBdBGmLCUhBadR","flowId":"flow-concurrency-parallel-subflow-kill"}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:46:20.037640Z"}}

java.lang.RuntimeException: Execution 6sXcTVrDUskytbHfUuIg7c is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"6sXcTVrDUskytbHfUuIg7c","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3qUmUNmE1fhALBkTfmpuOz","executionId":"6sXcTVrDUskytbHfUuIg7c","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:46:30.919094Z"},{"state":"RUNNING","date":"2025-12-19T13:46:30.981669Z"}],"durationOrComputeIt":9.335822585,"startDate":"2025-12-19T13:46:30.919094Z"}}],"labels":[{"key":"system.correlationId","value":"5hje19siWdKFE3ORYtsO5P"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:46:20.037635Z"},{"state":"QUEUED","date":"2025-12-19T13:46:20.194976Z"},{"state":"RUNNING","date":"2025-12-19T13:46:30.882752Z"}],"durationOrComputeIt":20.217573871,"startDate":"2025-12-19T13:46:20.037635Z"},"originalId":"6sXcTVrDUskytbHfUuIg7c","trigger":{"id":"flow1","type":"io.kestra.plugin.core.flow.Subflow","variables":{"taskId":"flow1","flowRevision":1,"namespace":"io.kestra.tests","executionId":"5hje19siWdKFE3ORYtsO5P","taskRunId":"Xs83yPgdBdBGmLCUhBadR","flowId":"flow-concurrency-parallel-subflow-kill"}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:46:20.037640Z"}}
	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.888
java.lang.RuntimeException: Execution 3i9rmWTF0LDthIfTYBzpay is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3i9rmWTF0LDthIfTYBzpay","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"5yrSVfcOujgM66nfODHSbE","executionId":"3i9rmWTF0LDthIfTYBzpay","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:46:56.493008Z"},{"state":"RUNNING","date":"2025-12-19T13:46:56.541002Z"}],"startDate":"2025-12-19T13:46:56.493008Z","durationOrComputeIt":9.103506213}}],"labels":[{"key":"system.correlationId","value":"7X6HEw4esHldVEOladgz0b"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:46:45.239040Z"},{"state":"QUEUED","date":"2025-12-19T13:46:45.447746Z"},{"state":"RUNNING","date":"2025-12-19T13:46:56.433728Z"}],"startDate":"2025-12-19T13:46:45.239040Z","durationOrComputeIt":20.358613208},"originalId":"3i9rmWTF0LDthIfTYBzpay","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow2","namespace":"io.kestra.tests","taskRunId":"6YTXbIDAtsGogZ7n6mZvJf","executionId":"7X6HEw4esHldVEOladgz0b","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:46:45.239048Z"}}

java.lang.RuntimeException: Execution 3i9rmWTF0LDthIfTYBzpay is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3i9rmWTF0LDthIfTYBzpay","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill-child","flowRevision":1,"taskRunList":[{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"5yrSVfcOujgM66nfODHSbE","executionId":"3i9rmWTF0LDthIfTYBzpay","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:46:56.493008Z"},{"state":"RUNNING","date":"2025-12-19T13:46:56.541002Z"}],"startDate":"2025-12-19T13:46:56.493008Z","durationOrComputeIt":9.103506213}}],"labels":[{"key":"system.correlationId","value":"7X6HEw4esHldVEOladgz0b"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2025-12-19T13:46:45.239040Z"},{"state":"QUEUED","date":"2025-12-19T13:46:45.447746Z"},{"state":"RUNNING","date":"2025-12-19T13:46:56.433728Z"}],"startDate":"2025-12-19T13:46:45.239040Z","durationOrComputeIt":20.358613208},"originalId":"3i9rmWTF0LDthIfTYBzpay","trigger":{"id":"flow2","type":"io.kestra.plugin.core.flow.Subflow","variables":{"flowId":"flow-concurrency-parallel-subflow-kill","taskId":"flow2","namespace":"io.kestra.tests","taskRunId":"6YTXbIDAtsGogZ7n6mZvJf","executionId":"7X6HEw4esHldVEOladgz0b","flowRevision":1}},"deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:46:45.239048Z"}}
	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.MysqlServiceLivenessCoordinatorTest > shouldReEmitTasksWhenWorkerIsDetectedAsNonResponding() failed ❌ in 10.818
org.opentest4j.AssertionFailedError: 
Expecting value to be true but was false

org.opentest4j.AssertionFailedError: 
Expecting value to be true but was false
	at app//io.kestra.jdbc.runner.JdbcServiceLivenessCoordinatorTest.shouldReEmitTasksWhenWorkerIsDetectedAsNonResponding(JdbcServiceLivenessCoordinatorTest.java:129)
	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)

jdbc-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyKilled() failed ❌ in 23.371
java.lang.RuntimeException: Execution 3ifA8aJX4VdSixIjNwPuQG is currently at the status KILLING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-killed","id":"3ifA8aJX4VdSixIjNwPuQG","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3ifA8aJX4VdSixIjNwPuQG"}],"state":{"current":"KILLING","histories":[{"state":"CREATED","date":"2025-12-19T13:50:42.614084Z"},{"state":"QUEUED","date":"2025-12-19T13:50:42.711033Z"},{"state":"KILLING","date":"2025-12-19T13:50:44.356101Z"}],"startDate":"2025-12-19T13:50:42.614084Z","durationOrComputeIt":20.776169542},"originalId":"3ifA8aJX4VdSixIjNwPuQG","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:50:42.614090Z"}}

java.lang.RuntimeException: Execution 3ifA8aJX4VdSixIjNwPuQG is currently at the status KILLING which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-killed","id":"3ifA8aJX4VdSixIjNwPuQG","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3ifA8aJX4VdSixIjNwPuQG"}],"state":{"current":"KILLING","histories":[{"state":"CREATED","date":"2025-12-19T13:50:42.614084Z"},{"state":"QUEUED","date":"2025-12-19T13:50:42.711033Z"},{"state":"KILLING","date":"2025-12-19T13:50:44.356101Z"}],"startDate":"2025-12-19T13:50:42.614084Z","durationOrComputeIt":20.776169542},"originalId":"3ifA8aJX4VdSixIjNwPuQG","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:50:42.614090Z"}}
	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: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-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyQueueKilled() failed ❌ in 30.189
java.lang.RuntimeException: Execution 3ZYPjJH1Vd1YqiVaReW2Dv is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"3ZYPjJH1Vd1YqiVaReW2Dv","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3ZYPjJH1Vd1YqiVaReW2Dv"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-19T13:51:03.687956Z"}],"startDate":"2025-12-19T13:51:03.687956Z","durationOrComputeIt":30.017935825},"originalId":"3ZYPjJH1Vd1YqiVaReW2Dv","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:51:03.687960Z"}}

java.lang.RuntimeException: Execution 3ZYPjJH1Vd1YqiVaReW2Dv is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-queue-killed","id":"3ZYPjJH1Vd1YqiVaReW2Dv","namespace":"io.kestra.tests","flowId":"flow-concurrency-queue-killed","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3ZYPjJH1Vd1YqiVaReW2Dv"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-19T13:51:03.687956Z"}],"startDate":"2025-12-19T13:51:03.687956Z","durationOrComputeIt":30.017935825},"originalId":"3ZYPjJH1Vd1YqiVaReW2Dv","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:51:03.687960Z"}}
	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: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-postgres > io.kestra.runner.postgres.PostgresRunnerConcurrencyTest > flowConcurrencyParallelSubflowKill() failed ❌ in 30.830
java.lang.RuntimeException: Execution 3nQ2nNt5GckLzz1n9KeYfX is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3nQ2nNt5GckLzz1n9KeYfX","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3nQ2nNt5GckLzz1n9KeYfX"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-19T13:51:34.482937Z"}],"startDate":"2025-12-19T13:51:34.482937Z","durationOrComputeIt":30.024270035},"originalId":"3nQ2nNt5GckLzz1n9KeYfX","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:51:34.482950Z"}}

java.lang.RuntimeException: Execution 3nQ2nNt5GckLzz1n9KeYfX is currently at the status CREATED which is not the awaited one, full execution object:
{"tenantId":"flow-concurrency-parallel-subflow-kill","id":"3nQ2nNt5GckLzz1n9KeYfX","namespace":"io.kestra.tests","flowId":"flow-concurrency-parallel-subflow-kill","flowRevision":1,"labels":[{"key":"system.correlationId","value":"3nQ2nNt5GckLzz1n9KeYfX"}],"state":{"current":"CREATED","histories":[{"state":"CREATED","date":"2025-12-19T13:51:34.482937Z"}],"startDate":"2025-12-19T13:51:34.482937Z","durationOrComputeIt":30.024270035},"originalId":"3nQ2nNt5GckLzz1n9KeYfX","deleted":false,"metadata":{"attemptNumber":1,"originalCreatedDate":"2025-12-19T13:51:34.482950Z"}}
	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: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)

@MilosPaunovic MilosPaunovic moved this from To review to On hold in Pull Requests Dec 24, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

Status: On hold

Development

Successfully merging this pull request may close these issues.

3 participants