Skip to content

test(scheduler): Fix AbstractSchedulerWorkerGroupTest + Cli tenant create#14951

Merged
Skraye merged 1 commit intokestra_wipfrom
tests/wip_fixing
Mar 6, 2026
Merged

test(scheduler): Fix AbstractSchedulerWorkerGroupTest + Cli tenant create#14951
Skraye merged 1 commit intokestra_wipfrom
tests/wip_fixing

Conversation

@Skraye
Copy link
Member

@Skraye Skraye commented Mar 6, 2026

Also modified the Kestra Test to allows running the controller without workers

@github-project-automation github-project-automation bot moved this to To review in Pull Requests Mar 6, 2026
@Skraye Skraye requested a review from loicmathieu March 6, 2026 10:07
@github-actions
Copy link
Contributor

github-actions bot commented Mar 6, 2026 •
edited
Loading

🐋 Docker image

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

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

🧪 Java Unit Tests

TestsPassed ☑️Skipped ⚠️Failed ❌️Time ⏱
Java Tests Report4224 ran4199 ✅22 ⚠️3 ❌39m 59s 277ms
TestResultTime ⏱
Java Tests Report
H2ServiceLivenessCoordinatorTest.initializationError❌ failure16ms
MysqlServiceLivenessCoordinatorTest.initializationError❌ failure4ms
PostgresServiceLivenessCoordinatorTest.initializationError❌ failure2ms

loicmathieu
loicmathieu approved these changes Mar 6, 2026
View reviewed changes
Copy link
Member

@loicmathieu loicmathieu left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@github-actions
Copy link
Contributor

github-actions bot commented Mar 6, 2026

Tests report quick summary:

failed ❌ > tests: 4224, success: 4199, skipped: 22, failed: 3

Project Status Success Skipped Failed
cli success ✅ 69 0 0
core success ✅ 1891 0 0
executor success ✅ 31 0 0
jdbc success ✅ 11 0 0
jdbc-h2 failed ❌ 527 0 1
jdbc-mysql failed ❌ 520 0 1
jdbc-postgres failed ❌ 520 0 1
processor success ✅ 7 0 0
queue success ✅ 28 0 0
runner-memory success ✅ 1 0 0
scheduler success ✅ 56 0 0
script success ✅ 11 0 0
storage-local success ✅ 64 0 0
webserver success ✅ 406 0 0
worker success ✅ 23 0 0
worker-controller success ✅ 56 0 0

Failed tests:

jdbc-h2 > io.kestra.runner.h2.H2ServiceLivenessCoordinatorTest > initializationError failed ❌ in 0.016 
java.io.UncheckedIOException: Error while building gRPC server

java.io.UncheckedIOException: Error while building gRPC server
	at io.kestra.controller.DefaultController.start(DefaultController.java:84)
	at io.kestra.executor.AbstractServiceLivenessCoordinatorTest.init(AbstractServiceLivenessCoordinatorTest.java:102)
	at java.base/java.lang.reflect.Method.invoke(Method.java:565)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:511)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1450)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:2019)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:187)
Caused by: java.io.IOException: Failed to bind to address 0.0.0.0/0.0.0.0:57827
	at io.grpc.netty.NettyServer.start(NettyServer.java:341)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:185)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:94)
	at io.kestra.controller.DefaultController.start(DefaultController.java:79)
	... 6 more
Caused by: java.net.BindException: Address already in use
	at java.base/sun.nio.ch.Net.bind0(Native Method)
	at java.base/sun.nio.ch.Net.bind(Net.java:522)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.netBind(ServerSocketChannelImpl.java:335)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:297)
	at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:148)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:434)
	at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1353)
	at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:492)
	at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:471)
	at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:994)
	at io.netty.channel.Channel.bind(Channel.java:302)
	at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:384)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:148)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:141)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:535)
	at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:201)
	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1195)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:1474)
jdbc-mysql > io.kestra.runner.mysql.MysqlServiceLivenessCoordinatorTest > initializationError failed ❌ in 0.004 
java.io.UncheckedIOException: Error while building gRPC server

java.io.UncheckedIOException: Error while building gRPC server
	at io.kestra.controller.DefaultController.start(DefaultController.java:84)
	at io.kestra.executor.AbstractServiceLivenessCoordinatorTest.init(AbstractServiceLivenessCoordinatorTest.java:102)
	at java.base/java.lang.reflect.Method.invoke(Method.java:565)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:511)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1450)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:2019)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:187)
Caused by: java.io.IOException: Failed to bind to address 0.0.0.0/0.0.0.0:58760
	at io.grpc.netty.NettyServer.start(NettyServer.java:341)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:185)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:94)
	at io.kestra.controller.DefaultController.start(DefaultController.java:79)
	... 6 more
Caused by: java.net.BindException: Address already in use
	at java.base/sun.nio.ch.Net.bind0(Native Method)
	at java.base/sun.nio.ch.Net.bind(Net.java:522)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.netBind(ServerSocketChannelImpl.java:335)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:297)
	at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:148)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:434)
	at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1353)
	at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:492)
	at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:471)
	at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:994)
	at io.netty.channel.Channel.bind(Channel.java:302)
	at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:384)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:148)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:141)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:535)
	at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:201)
	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1195)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:1474)
jdbc-postgres > io.kestra.runner.postgres.PostgresServiceLivenessCoordinatorTest > initializationError failed ❌ in 0.002 
java.io.UncheckedIOException: Error while building gRPC server

java.io.UncheckedIOException: Error while building gRPC server
	at io.kestra.controller.DefaultController.start(DefaultController.java:84)
	at io.kestra.executor.AbstractServiceLivenessCoordinatorTest.init(AbstractServiceLivenessCoordinatorTest.java:102)
	at java.base/java.lang.reflect.Method.invoke(Method.java:565)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:511)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1450)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:2019)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:187)
Caused by: java.io.IOException: Failed to bind to address 0.0.0.0/0.0.0.0:42424
	at io.grpc.netty.NettyServer.start(NettyServer.java:341)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:185)
	at io.grpc.internal.ServerImpl.start(ServerImpl.java:94)
	at io.kestra.controller.DefaultController.start(DefaultController.java:79)
	... 6 more
Caused by: java.net.BindException: Address already in use
	at java.base/sun.nio.ch.Net.bind0(Native Method)
	at java.base/sun.nio.ch.Net.bind(Net.java:522)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.netBind(ServerSocketChannelImpl.java:335)
	at java.base/sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:297)
	at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:148)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:434)
	at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1353)
	at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:492)
	at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:471)
	at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:994)
	at io.netty.channel.Channel.bind(Channel.java:302)
	at io.netty.bootstrap.AbstractBootstrap$2.run(AbstractBootstrap.java:384)
	at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:148)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:141)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:535)
	at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:201)
	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1195)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:1474)

Develocity build scan: https://develocity.kestra.io/s/rvaq55vn5od2w

@Skraye Skraye merged commit 1389660 into kestra_wip Mar 6, 2026
8 of 10 checks passed
@Skraye Skraye deleted the tests/wip_fixing branch March 6, 2026 10:55
@github-project-automation github-project-automation bot moved this from To review to Done in Pull Requests Mar 6, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@loicmathieu loicmathieu loicmathieu approved these changes

Assignees

No one assigned

Labels

None yet

Projects

Pull Requests
Status: Done

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@Skraye @loicmathieu