dieriba
6339775404
feat: add gcp trigger ( #5501 )
...
* update: add migration for gcp_trigger table, add cli method gcp and add gcp_trigger args for github ci
* update: add gcp module and routing it in lib.rs
* update: added gcp type to TRIGGER KIND type in db, add new feature condition to try_get_fn and added gcp_trigger feature in cargo file
* update: add ui for gcp trigger, added missing triggers type for job kin, add gcp trigger in deploy to functionallity
* adding google cloud crate
* update: handle pull and push delivery
* update: handle pull and push delivery
* update: handle push event, changed front ui
* update: ui
* fix: capture for gcp
* update: automatically manage pub sub subscription and refactoring
* capture done
* update cli types
* fix: wrong func argument and type openapi
* fix: missing import
* update .sqlx
* update: svg color and remove pulse button for capture push gcp
* update: handle deployto
* update script helper and link to hub gcp script/flow
* update gcp representation
* update: add confirmation modal
* add unique index to mitigate same subscriber id, fix `zombie worker`, update test connection logic
* Update frontend/src/lib/components/triggers/gcp/GcpTriggerEditorInner.svelte
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* Update cli/gen/services.gen.ts
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* nits
* update repo ref
* fix feature function
* update dependencies
* update .sqlx
* fix missing import
* update: handle existing subscription and creating new one or update it
* fix ee build
* handle existing config properly
* update .sqlx
* update .sqlx
* remove unused
* update documentation link fix ci
* use on instance of empty_string_as_none fn
* update refo ref
* updat script_helper
* update ui
* update migration
* add missing arguments
* fix and nits
* update repo ref
* remove unused
* nits
* add doc links
* nits
* Update frontend/src/lib/components/triggers/gcp/GcpTriggerPanel.svelte
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* Update frontend/src/lib/components/triggers/gcp/GcpTriggerEditorInner.svelte
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* use trigger path as default route path
* update .sqlx
* update repo ref
* update ref
* update route path
* update types
* fix deploy to
* nits
* update repo ref
* update .sqlx
* Update frontend/src/lib/components/triggers/gcp/GcpTriggerEditorConfigSection.svelte
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* nits
* nits
* nits
* remove dupliacte fn and update repo ref
* remove unused import
* fix missing import
* fix: wong name var
* update script helper and template script
* Update frontend/src/lib/script_helpers.ts
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* Update ee-repo-ref.txt
---------
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
Co-authored-by: HugoCasa <hugo@casademont.ch >
2025-04-10 20:39:01 +00:00
Ruben Fiszel
63fa499015
feat: agent workers v2 using http ( #5588 )
2025-04-10 00:56:11 +00:00
Ruben Fiszel
1bb402bcfc
fix benchmarks
2025-04-03 21:17:13 +00:00
HugoCasa
3d3250194d
fix: correctly run empty flow with preprocessor from UI ( #5537 )
2025-03-28 11:26:26 -07:00
Ruben Fiszel
f3a0af8fe6
bump versions ( #5526 )
...
* all
* version bump
* ci
* fix bump
* fix
2025-03-27 23:57:09 +01:00
Ruben Fiszel
2e74595a37
nit, add scheduled_for in logs
2025-03-27 21:28:21 +01:00
HugoCasa
63fe9c1852
fix: add missing privileged hub script for app slack reports ( #5515 )
2025-03-26 23:15:03 +01:00
Ruben Fiszel
5573d88695
perf: cache workspace premium check
2025-03-25 02:00:51 +01:00
Ruben Fiszel
ec11d577c6
fix: improve cancel for flows with many substeps
2025-03-24 22:00:15 +01:00
Ruben Fiszel
3edca4bc91
perf: optimize number of queries needed for job run ( #5504 )
...
* optPerf
* update sqlx
* update sqlx
2025-03-24 20:12:26 +01:00
HugoCasa
551c0ecd6a
perf: improve perf of get completed flow node ( #5418 )
...
* perf: improve perf of get completed flow node
* better
* nit
* nits
---------
Co-authored-by: Ruben Fiszel <ruben@windmill.dev >
2025-03-19 10:51:30 +01:00
Ruben Fiszel
fb532e0b85
nit move away from using views
2025-03-19 10:48:43 +01:00
Ruben Fiszel
880db319e8
feat: filter by worker + backend perf opt ( #5489 )
...
* all
* all
* all
* refactor
* sqlx
* ref
* impr
* fix
* fix
* fix
* ee private
2025-03-19 09:55:53 +01:00
Ruben Fiszel
8a7b119d4d
improve concurrency limits II ( #5485 )
2025-03-17 17:24:50 +01:00
Ruben Fiszel
eee7d33bd8
fix: improve concurrency limit check performances
2025-03-17 00:53:14 +01:00
Ruben Fiszel
8d71124c20
DISABLE_CONCURRENCY_LIMIT 2
2025-03-16 18:22:41 +01:00
Ruben Fiszel
85d13e650d
DISABLE_CONCURRENCY_LIMIT
2025-03-16 17:45:40 +01:00
Ruben Fiszel
e8bb307502
fix: improve row lock contention on concurrency counter
2025-03-16 17:20:39 +01:00
Ruben Fiszel
11ed81a6c7
nit zombie job monitoring
2025-03-11 07:08:28 +01:00
Ruben Fiszel
fba9e7ef03
fix: improve cancel performance
2025-03-03 23:50:13 +01:00
Ruben Fiszel
c90fe387e8
fix: schedules do not accept 5 units cron syntax on update/create anymore
2025-02-20 17:59:32 +01:00
Ruben Fiszel
588ff79364
make benchmarks even more stable
2025-02-18 08:43:03 +01:00
Ruben Fiszel
953082681e
fix: improve que job indices for faster performances
2025-02-17 21:26:46 +01:00
Lucas Abel
bf206515e8
fix(backend): improve schedule queries plan to leverage indices better for performance ( #5273 )
...
* backend: fix schedule queries plan
* rework
* fix skipped as non success
* update sqlx
* update
* all
* fix npm run check
---------
Co-authored-by: Ruben Fiszel <ruben@windmill.dev >
2025-02-12 16:34:03 +01:00
Ruben Fiszel
4828a77f21
fix: fix concurrent limit jobs non restarting
2025-02-10 11:33:19 +01:00
Ruben Fiszel
403826fca9
fix: worker name in job + better timeout handling for same_worker jobs ( #5248 )
2025-02-08 22:20:06 +01:00
Lucas Abel
4849af04de
backend: fix workflow as code ( #5239 )
...
* backend: improve `/get_job_update` after v2
* backend: insert missing `workflow_as_code_status` on completion
also insert `flow_status` from so we can remove the query when `_duration` is above 500
* backend: fix workflow_as_code after v2
* backend: add `workflow_as_code` worker test
2025-02-07 12:27:43 +01:00
Lucas Abel
d51c3080f7
backend: use v2 tables through views where possible (v2 phase 3) ( #5119 )
2025-02-06 12:43:24 +01:00
Lucas Abel
e0d99ab703
backend: check queries to queue and completed_job where possible (v2 phase 2) ( #5125 )
2025-02-06 12:39:32 +01:00
Lucas Abel
3e8e0c653e
backend: migrate job tables to v2 schema (v2 phase 1) ( #5084 )
2025-02-06 12:37:11 +01:00
Ruben Fiszel
abf094bcbc
fix uv install for nsjail ( #5222 )
2025-02-06 00:00:33 +01:00
Ruben Fiszel
90ba65ae20
improve error messages for internal err
2025-02-05 16:32:01 +01:00
dieriba
316a2167e7
feat: postgres triggers ( #4860 )
...
* feat: init database triggers
* feat: ✨ wip: database_triggers
* feat: ✨ add database triggers front view
* feat: 🚧 database_triggers
* feat: 🚧 add definition in yaml, updated backend code and added migration
* feat: 🚧 updated migration file, update openapi.yml, updated database_triggers page and backend function
* fix: struct rust
* feat: 🚧 update migrate, database trigger backend function fixed
* feat: 🚧 add resource picker front, update backend function
* feat: 🚧 edit inner database inner, update triggers
* feat: 🚧 database_triggers
* feat: 🚧 update openapi yaml, prettied websocker trigger
* feat: 🚧 database_triggers
* feat: 🚧 add resource module, update variable file, working on main loop for database_trigger
* feat: 🐛 working sqlx query
* feat: 🚧 fix query with sqlx, added main loop
* feat: 🚧 add new column database_trigg
* feat: 🛂 run jobs works
* feat: 🚧 handling slot name and replication
* feat: restructring triggers, decoding trigger message on work
* feat: 🚧 database_trigger
* feat: 🚧
* feat: 🚧 converter done, work on custom script
* feat: 🚧 multiple trigger
* feat: 🚧 adding new argument function
* feat: 🚧 database_trigger
* feat: 🚧 add generate template for front, update script picker
* feat: 🚧 template script fix bug, work on restructing backend logic
* feat: 🚧 update autogenerated script, add persistence state for template script
* feat: 🚧 update structure client
* feat: 🚧 rewrited crud function
* feat: 🚧 added publication handler
* feat: 🚧 new ui finished
* feat: 🚧 added slot function hanlder finish front ux
* feat: ✨ ux improvement done, backend logic done
* feat: 🐛 fix where clause
* feat:
* feat:
* chore: update .sqlx and remove empty package
* fix: update publication and remove unneccessary print
* feat: finish converter to json, remove save button, remove unused crate
* feat: update migration for database trigger, fixed query, fixed frontend error with missing feature on back
* chore: update .sqlx
* chore: update sqlx
* chore: .sqlx
* chore: add unused
* fix: use right database resource in back and front
* fix build
* refactor:
* fix sqlx
* nits: retrieve all script from database trigger editor
* fix: template script object, fix route name
* merge main
* feat: rework ux
* feat/finish ux and update backend logic
* feat: database_trigger
* feat: database_trigger
* chore: update sqlx
* chore: fix ci
* nits: fix worker.rs
* feat: database_trigger
* Update frontend/src/lib/components/triggers/database/DatabaseTriggersPanel.svelte
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
* feat:
* fix ci
* nits: database to postgres
* nits: fix .sqlx
* feat: add link to original code and open tab functionallity
* nits: update .sqlx
* nits: fix request type and yaml file
* nits: add abel suggestion
* fix: update .sqlx
* fix: update .sqlx
* nits: add comment to hex.rs
* nits: remove features, rename database to postgres name
* nits: replace database name by postgres
* nits: database name to postgres
* nits: update .sqlx
* nits: update .sqlx
* nit
* nit
* nits
* nit
* nits
* nits
* nits
* nits
* fix sqlx
* nits: update .vscode
---------
Co-authored-by: HugoCasa <hugo@casademont.ch >
Co-authored-by: ellipsis-dev[bot] <65095814+ellipsis-dev[bot]@users.noreply.github.com>
Co-authored-by: Ruben Fiszel <ruben@windmill.dev >
2025-01-24 15:12:41 +01:00
Lucas Abel
ba711c48df
backend: always prioritize flow steps ( #5108 )
...
When a flow start, his flow steps have lower priority than already scheduled jobs, hence steps are only executed when the queue is drained which considerably increase flow execution time when queue size is significant.
This add a very low priority to flow steps in order to prioritize finishing a started flow over new jobs.
2025-01-21 09:27:40 +01:00
HugoCasa
04fbda28e8
feat: on behalf of ( #5058 )
...
* feat: on behalf of
* fix
* revert mistakke
* temp ee ref
* renaming + CLI
* sqlx
* nits + ee ref
2025-01-14 18:32:25 +01:00
HugoCasa
96d31f9577
prevent cancelling schedule next tick + remove need of flow_status inside add_completed_job ( #5022 )
2025-01-13 14:26:28 +01:00
HugoCasa
a3aa091d1e
fea(backend): return 500 on sync webhook/route error ( #5049 )
...
* fea(backend): return 500 on sync webhook/route error
* fix sqlx
2025-01-13 12:25:06 +01:00
Lucas Abel
8586476a13
backend: do not force get_schedule_opt to be within a transaction ( #5019 )
2025-01-06 09:36:57 +01:00
Lucas Abel
abf63a6560
fix(backend): fix has_failure_module only looking for raw_flow ( #5018 )
2025-01-06 09:21:17 +01:00
Lucas Abel
83d24cb9ab
cache: better cache system ( #4951 )
...
* cache: consider source as untrusted
* cache: better scoped cache
* cache: non-lazy flow value parse error
* fixup! cache: consider source as untrusted
* fixup! cache: consider source as untrusted
* fixup! cache: better scoped cache
2024-12-20 11:19:57 +01:00
Lucas Abel
fb536df066
fix: fix redeploying flows with attached schedules
2024-12-18 18:56:30 +01:00
Lucas Abel
0ee3a77a7e
pass cargo check ( #4949 )
2024-12-18 16:21:37 +01:00
Lucas Abel
bded6028f1
backend: pass cargo check --all-features ( #4946 )
2024-12-18 12:37:31 +01:00
Ruben Fiszel
13be0cd1c8
fix: fix relative imports in cached flow scripts
2024-12-18 11:34:07 +01:00
Lucas Abel
977ac5c3f3
feat(cache): remove persistent raw values from queue ( #4866 )
...
* feat(cache): remove persistent raw values from queue
* test: add tests and fix discovered regressions
* fix csharp executor after rebase
* invalidate script cache after locking
* fix lite flow version race
* fix flow dependencies lock race
* update version flag to `v.1.440`
2024-12-16 17:10:16 +01:00
HugoCasa
83a60cbc51
feat: add multipart/form-data support ( #4927 )
...
* feat: add multipart/form-data support
* nits
2024-12-15 10:53:12 +01:00
Ruben Fiszel
b169ddb9d3
nit
2024-12-15 01:00:44 +01:00
Lucas Abel
74a89552c7
cleanup is_flow usage and impl ( #4923 )
2024-12-13 18:08:01 +01:00
Ruben Fiszel
3634ade41b
fix: flow node default tag
2024-12-13 17:51:08 +01:00
HugoCasa
563a492008
feat: accept direct file upload for webhook/http (s3) ( #4903 )
...
* feat: accept direct file upload for webhook/http (s3)
* nit
* nit
2024-12-12 00:33:19 +01:00
