Skip to content

feat(core): implement BINDING TYPE and NAMESPACE filters#14829

Open
ammeek wants to merge 1 commit intodevelopfrom
feat/bindings-filters
Open

feat(core): implement BINDING TYPE and NAMESPACE filters#14829
ammeek wants to merge 1 commit intodevelopfrom
feat/bindings-filters

Conversation

@ammeek
Copy link
Contributor

@ammeek ammeek commented Feb 26, 2026

✨ Description

What does this PR change?
Add BINDING TYPE and NAMESPACE filters

🔗 Related Issue

relates to kestra-io/kestra-ee#6256

🛠️ Backend Checklist

  • Code compiles successfully and passes all checks
  • All unit and integration tests pass

@github-actions
Copy link
Contributor

github-actions bot commented Feb 26, 2026

🐋 Docker image

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

🧪 Java Unit Tests

TestsPassed ☑️Skipped ⚠️Failed ❌️Time ⏱
Java Tests Report3666 ran3652 ✅13 ⚠️1 ❌1h 26m 58s 768ms
TestResultTime ⏱
Java Tests Report
ExecutionControllerRunnerTest.restartExecutionFromTaskIdWithInputs()❌ failure15s 329ms

@github-actions
Copy link
Contributor

github-actions bot commented Feb 26, 2026

Tests report quick summary:

failed ❌ > tests: 3666, success: 3652, skipped: 13, failed: 1

Project Status Success Skipped Failed
cli success ✅ 80 0 0
core success ✅ 1865 0 0
executor success ✅ 4 0 0
jdbc success ✅ 12 0 0
jdbc-h2 success ✅ 472 0 0
jdbc-mysql success ✅ 475 0 0
jdbc-postgres success ✅ 475 0 0
processor success ✅ 7 0 0
runner-memory success ✅ 1 0 0
scheduler success ✅ 24 0 0
script success ✅ 12 0 0
storage-local success ✅ 64 0 0
webserver failed ❌ 169 0 1
worker success ✅ 5 0 0

Failed tests:

webserver > io.kestra.webserver.controllers.api.ExecutionControllerRunnerTest > restartExecutionFromTaskIdWithInputs() failed ❌ in 15.329
java.lang.RuntimeException: Execution 1vMMOit3cGItuU0eExIlPn is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"main","id":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","flowRevision":3,"taskRunList":[{"id":"4UiaOtjddi9uEvudKFxFLy","executionId":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","taskId":"hello","attempts":[{"state":{"current":"SUCCESS","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.798921Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.798922Z"},{"state":"SUCCESS","date":"2026-02-27T16:05:01.799648Z"}],"duration":0.000727000,"endDate":"2026-02-27T16:05:01.799648Z","startDate":"2026-02-27T16:05:01.798921Z"},"workerId":"ae3855df-9bd9-45c7-9d24-986f780211d7"}],"outputs":{},"state":{"current":"SUCCESS","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.785785Z"},{"state":"SUBMITTED","date":"2026-02-27T16:05:01.789082Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.796052Z"},{"state":"SUCCESS","date":"2026-02-27T16:05:01.799681Z"}],"duration":0.013896000,"endDate":"2026-02-27T16:05:01.799681Z","startDate":"2026-02-27T16:05:01.785785Z"}},{"id":"7dAdeATybjsERpD4L9tMdX","executionId":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","taskId":"fail","attempts":[{"state":{"current":"FAILED","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.847843Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.847844Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.848931Z"}],"duration":0.001088000,"endDate":"2026-02-27T16:05:01.848931Z","startDate":"2026-02-27T16:05:01.847843Z"},"workerId":"ae3855df-9bd9-45c7-9d24-986f780211d7"}],"outputs":{},"state":{"current":"RESTARTED","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.819637Z"},{"state":"SUBMITTED","date":"2026-02-27T16:05:01.822346Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.847661Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.848961Z"},{"state":"RESTARTED","date":"2026-02-27T16:05:02.017083Z"}],"startDate":"2026-02-27T16:05:01.819637Z"}}],"inputs":{"condition":"success"},"labels":[{"key":"system.correlationId","value":"3R3LC3mIrx92A0MTQjQeyT"},{"key":"system.replay","value":"true"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.772079Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.786091Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.881547Z"},{"state":"RESTARTED","date":"2026-02-27T16:05:02.018396Z"},{"state":"RUNNING","date":"2026-02-27T16:05:02.049098Z"}],"startDate":"2026-02-27T16:05:01.772079Z"},"parentId":"3R3LC3mIrx92A0MTQjQeyT","originalId":"3R3LC3mIrx92A0MTQjQeyT","deleted":false,"metadata":{"attemptNumber":2,"originalCreatedDate":"2026-02-27T16:05:01.772084Z"}}

java.lang.RuntimeException: Execution 1vMMOit3cGItuU0eExIlPn is currently at the status RUNNING which is not the awaited one, full execution object:
{"tenantId":"main","id":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","flowRevision":3,"taskRunList":[{"id":"4UiaOtjddi9uEvudKFxFLy","executionId":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","taskId":"hello","attempts":[{"state":{"current":"SUCCESS","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.798921Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.798922Z"},{"state":"SUCCESS","date":"2026-02-27T16:05:01.799648Z"}],"duration":0.000727000,"endDate":"2026-02-27T16:05:01.799648Z","startDate":"2026-02-27T16:05:01.798921Z"},"workerId":"ae3855df-9bd9-45c7-9d24-986f780211d7"}],"outputs":{},"state":{"current":"SUCCESS","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.785785Z"},{"state":"SUBMITTED","date":"2026-02-27T16:05:01.789082Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.796052Z"},{"state":"SUCCESS","date":"2026-02-27T16:05:01.799681Z"}],"duration":0.013896000,"endDate":"2026-02-27T16:05:01.799681Z","startDate":"2026-02-27T16:05:01.785785Z"}},{"id":"7dAdeATybjsERpD4L9tMdX","executionId":"1vMMOit3cGItuU0eExIlPn","namespace":"io.kestra.tests","flowId":"condition_with_input","taskId":"fail","attempts":[{"state":{"current":"FAILED","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.847843Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.847844Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.848931Z"}],"duration":0.001088000,"endDate":"2026-02-27T16:05:01.848931Z","startDate":"2026-02-27T16:05:01.847843Z"},"workerId":"ae3855df-9bd9-45c7-9d24-986f780211d7"}],"outputs":{},"state":{"current":"RESTARTED","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.819637Z"},{"state":"SUBMITTED","date":"2026-02-27T16:05:01.822346Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.847661Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.848961Z"},{"state":"RESTARTED","date":"2026-02-27T16:05:02.017083Z"}],"startDate":"2026-02-27T16:05:01.819637Z"}}],"inputs":{"condition":"success"},"labels":[{"key":"system.correlationId","value":"3R3LC3mIrx92A0MTQjQeyT"},{"key":"system.replay","value":"true"}],"state":{"current":"RUNNING","histories":[{"state":"CREATED","date":"2026-02-27T16:05:01.772079Z"},{"state":"RUNNING","date":"2026-02-27T16:05:01.786091Z"},{"state":"FAILED","date":"2026-02-27T16:05:01.881547Z"},{"state":"RESTARTED","date":"2026-02-27T16:05:02.018396Z"},{"state":"RUNNING","date":"2026-02-27T16:05:02.049098Z"}],"startDate":"2026-02-27T16:05:01.772079Z"},"parentId":"3R3LC3mIrx92A0MTQjQeyT","originalId":"3R3LC3mIrx92A0MTQjQeyT","deleted":false,"metadata":{"attemptNumber":2,"originalCreatedDate":"2026-02-27T16:05:01.772084Z"}}
	at io.kestra.core.runners.TestRunnerUtils.awaitExecution(TestRunnerUtils.java:259)
	at io.kestra.core.runners.TestRunnerUtils.emitAndAwaitExecution(TestRunnerUtils.java:234)
	at io.kestra.core.runners.TestRunnerUtils.awaitChildExecution(TestRunnerUtils.java:369)
	at io.kestra.webserver.controllers.api.ExecutionControllerRunnerTest.restartExecutionFromTaskIdWithInputs(ExecutionControllerRunnerTest.java:628)
	at java.base/java.lang.reflect.Method.invoke(Method.java:565)
	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:1604)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1604)


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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

Status: To review

Development

Successfully merging this pull request may close these issues.

1 participant