feat(trigger): add support for concurrent trigger execution (#311)

[fhussonnois]

Fixes: #311

[github-actions]

🐋 Docker image

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

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

🧪 Java Unit Tests

	Tests	Passed ☑️	Skipped ⚠️	Failed ❌️	Time ⏱
Java Tests Report	3633 ran	3619 ✅	12 ⚠️	2 ❌	36m 46s 24ms

Test	Result	Time ⏱
Java Tests Report
JsonSchemaGeneratorTest.trigger()	❌ failure	1s 380ms
FlowControllerTest.updateFlowFlowFromJson()	❌ failure	1m 53s 60ms

[github-actions]

Tests report quick summary:

failed ❌ > tests: 3633, success: 3619, skipped: 12, failed: 2

Project	Status	Success	Skipped	Failed
cli	success ✅	78	0	0
core	failed ❌	1666	0	1
executor	success ✅	4	0	0
jdbc	success ✅	10	0	0
jdbc-h2	success ✅	464	0	0
jdbc-mysql	success ✅	466	0	0
jdbc-postgres	success ✅	466	0	0
processor	success ✅	7	0	0
runner-memory	success ✅	1	0	0
scheduler	success ✅	23	0	0
script	success ✅	11	0	0
storage-local	success ✅	64	0	0
webserver	failed ❌	366	0	1
worker	success ✅	5	0	0

Failed tests:

core > io.kestra.core.docs.JsonSchemaGeneratorTest > trigger() failed ❌ in 1.380

java.lang.AssertionError: &#10;Expected: (a map with size <3> and map containing ["conditions"->ANYTHING] and map containing ["stopAfter"->ANYTHING] and map containing ["type"->ANYTHING])&#10;     but: a map with size <3> map size was <4>

java.lang.AssertionError: 
Expected: (a map with size <3> and map containing ["conditions"->ANYTHING] and map containing ["stopAfter"->ANYTHING] and map containing ["type"->ANYTHING])
     but: a map with size <3> map size was <4>
	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:6)
	at io.kestra.core.docs.JsonSchemaGeneratorTest.lambda$trigger$4(JsonSchemaGeneratorTest.java:172)
	at io.kestra.core.Helpers.runApplicationContext(Helpers.java:74)
	at io.kestra.core.docs.JsonSchemaGeneratorTest.trigger(JsonSchemaGeneratorTest.java:168)
	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)

webserver > io.kestra.webserver.controllers.api.FlowControllerTest > updateFlowFlowFromJson() failed ❌ in 113.060

org.opentest4j.AssertionFailedError: Unexpected exception type thrown, expected: <io.micronaut.http.client.exceptions.HttpClientResponseException> but was: <io.micronaut.http.client.exceptions.ReadTimeoutException>

org.opentest4j.AssertionFailedError: Unexpected exception type thrown, expected: <io.micronaut.http.client.exceptions.HttpClientResponseException> but was: <io.micronaut.http.client.exceptions.ReadTimeoutException>
	at app//org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
	at app//org.junit.jupiter.api.AssertThrows.assertThrows(AssertThrows.java:67)
	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.FlowControllerTest.updateFlowFlowFromJson(FlowControllerTest.java:445)
	at java.base@21.0.9/java.lang.reflect.Method.invoke(Method.java:580)
	at app//io.micronaut.test.extensions.junit5.MicronautJunit5Extension$2.proceed(MicronautJunit5Extension.java:142)
	at app//io.micronaut.test.extensions.AbstractMicronautExtension.interceptEach(AbstractMicronautExtension.java:162)
	at app//io.micronaut.test.extensions.AbstractMicronautExtension.interceptTest(AbstractMicronautExtension.java:119)
	at app//io.micronaut.test.extensions.junit5.MicronautJunit5Extension.interceptTestMethod(MicronautJunit5Extension.java:129)
	at java.base@21.0.9/java.util.ArrayList.forEach(ArrayList.java:1596)
	at java.base@21.0.9/java.util.ArrayList.forEach(ArrayList.java:1596)
Caused by: io.micronaut.http.client.exceptions.ReadTimeoutException: Read Timeout
	at app//io.micronaut.http.client.exceptions.ReadTimeoutException.<clinit>(ReadTimeoutException.java:26)
	at app//io.micronaut.http.client.netty.DefaultHttpClient.lambda$exchange$15(DefaultHttpClient.java:935)
	at app//io.micronaut.core.execution.ImperativeExecutionFlowImpl.onErrorResume(ImperativeExecutionFlowImpl.java:112)
	at app//io.micronaut.core.execution.DelayedExecutionFlowImpl$OnErrorResume.apply(DelayedExecutionFlowImpl.java:393)
	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.completeExceptionally(DelayedExecutionFlowImpl.java:104)
	at app//io.micronaut.core.execution.ExecutionFlow.lambda$timeout$1(ExecutionFlow.java:191)
	at app//io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
	at app//io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:160)
	at app//io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:148)
	at app//io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:141)
	at app//io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:535)
	at app//io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:201)
	at app//io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1193)
	at app//io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at app//io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base@21.0.9/java.lang.Thread.run(Thread.java:1583)

---

Flaky tests report quick summary:

success ✅ > tests: 31, success: 29, skipped: 2, failed: 0

unfold for details

Project	Status	Success	Skipped	Failed
cli	success ✅	2	0	0
core	success ✅	5	0	0
jdbc	success ✅	2	0	0
jdbc-mysql	success ✅	6	0	0
jdbc-h2	success ✅	4	0	0
jdbc-postgres	success ✅	6	0	0
scheduler	success ✅	2	0	0
script	success ✅	1	0	0
webserver	success ✅	3	0	0