26 Commits

Author SHA1 Message Date
Loïc Mathieu
be5e24217b chore(system): extract the scheduler to its own module 2025-09-04 11:04:13 +02:00
Loïc Mathieu
a5724bcb18 chore(system): extract the executor to its own module 2025-09-04 11:04:13 +02:00
Loïc Mathieu
f3057d2d57 chore(system): extract the worker to its own module 2025-09-04 11:04:13 +02:00
Florian Hussonnois
55740133f0 chore(test): add module for jmh benchmarks 2025-05-22 09:46:54 +02:00
Florian Hussonnois
a090a4d807 feat: add E2E tests modules and github workflow
Changes:
* add new gradle module e2e-tests
* add new reusable github workflow e2e

Enhancement:
* update main workflow to use setup-build composite action
* update main workflow to use .plugin file for listing plugins
* update docker workflow to use .plugin file for listing plugins
2024-07-04 17:47:25 +02:00
Ludovic DEHON
bd5d5c5758 feat(core): move test utils to a proper package 2024-06-20 22:58:40 +02:00
Loïc Mathieu
76f7038b52 feat: Kestra Platform BOM 2024-06-20 15:15:22 +02:00
Loïc Mathieu
8bfdb58574 feat(script): move plugin-script library to Kestra itself 2024-04-30 11:52:37 +02:00
Florian Hussonnois
56884d5a72 refactor(core): migrate to standard Java ServiceLoader for plugins
Changes:
- add new top level interface `Plugin`
- add new `JsonDeserializer` aware of the `PluginRegistry`
- add new annotation processor for plugin
- migrate to hibernate-validator for the JSR-303 (no bean introspection dependencies)
- update all Validation annotations to be complitant with the JSR-303
- remove all KestraApplicationContext stuffs
- fix some tests

part-of: kestra-io/plugin-template-test#25
part-of: kestra-io/plugin-serdes#103
2024-04-24 16:15:08 +02:00
Ludovic DEHON
100d200fc1 feat(core): move kafka to ee (#995)
Co-authored-by: Loïc Mathieu <loikeseke@gmail.com>
2023-02-19 21:38:01 +01:00
Ludovic DEHON
06337f5b2c feat(jdbc): introduce h2 in memory runner 2022-06-17 10:43:52 +02:00
tchiotludo
1875f08634 feat(jdbc): first implementation of mysql & postgres repository 2022-06-17 10:43:52 +02:00
Ludovic DEHON
62db0ab193 feat(indexer-kafka-elasticsearch): introduce bulk indexer for kafka & elastic (#218) 2020-11-19 16:39:37 +01:00
tchiotludo
85ba7852ce chore(plugins): remove extracted package to plugin repository 2020-01-04 14:59:31 +01:00
tchiotludo
e40014b0b9 chore(name): rename to final name 2019-12-27 13:50:15 +01:00
Ludovic DEHON
1fef7509bb feat(ui): introduce web ui (#12)
Introduce a web ui with initial support for :
* Flows list  (optionally filter by namespace) 
* Flow Detail : 
  * Initial topology view
  * Flow Executions 
  * Edit flow 
  * Trigger flow
* Executions List  
* Executions Detail : 
  * Overview 
  * Gantt view 
  * Logs 
  * Initial topology view
2019-12-26 14:55:33 +01:00
tchiotludo
3af0ef4ae9 fix(core): introduce Listeners
Listeners allow to execute some task after the flow. They are still considered as a TaskRun and save in the execution. They can have condition.

- add SlackIncomingWebhook notifications task
- add SlackExecution task with a message about the result of the execution
2019-12-19 10:34:59 +01:00
tchiotludo
1a04f1eddf feat(task-serdes): introduce serdes tasks
Tasks package that will handle file conversion.

- new tasks: CsvReader & CsvWriter
- new tasks: JsonReader & JsonWriter
- Refactor the CsvToAvro to AvroWriter and handle conversion from all type depending on schema.
- Remove the task-avro in favor of a more general task-serdes
2019-12-16 11:05:46 +01:00
tchiotludo
2ede1e692b feat(repository-elasticsearch): Introduce elasticsearch repository
Implements FlowRepositoryInterface for ES
2019-11-20 11:29:43 +01:00
tchiotludo
0d0d72e831 feat(webserver): introduce webserver 2019-10-29 21:39:59 +01:00
tchiotludo
372d54cf78 feat(avro): introduce avro tasks 2019-10-19 14:08:09 +02:00
tchiotludo
14e3384be2 feat(task-gcp): introduce first gcp tasks
- BigQueryFetch
- GcsCopy
2019-10-19 14:06:24 +02:00
tchiotludo
bcc5798d7f feat(storage): initial commit of storage 2019-10-19 13:43:16 +02:00
tchiotludo
b4d026574c feat(queue): introduce Kafka Queue 2019-10-03 07:44:27 +02:00
tchiotludo
83c11ee119 refactor(core): separate to different module for runner-memory & local repository 2019-09-23 20:55:18 +02:00
tchiotludo
d57e30c0c0 Initial commit 2019-08-26 07:59:45 +02:00