Commit Graph

278 Commits

Author SHA1 Message Date
HugoCasa e46c2ea513 fix: improve license key ui (#4220)
* fix: improve license key ui

* fix: stop schedules on key expiration

* update ee ref
2024-08-11 01:01:24 +02:00
Ruben Fiszel 553c95d71b improve queue indices 2024-07-31 23:44:40 +02:00
Ruben Fiszel cd4a424456 improve job result deser 2024-07-31 02:32:33 +02:00
HugoCasa e2388989bb feat: get completed flow node result by api/download + eval list result json path optim (#4108)
* feat: get completed flow node result by api

* fix: missing file

* feat: fallback to completed job + fix dfs

* feat: download all results + eval improvement

* fix: nit regex

* fix: nit
2024-07-29 20:30:55 +02:00
Ruben Fiszel 12ec75551e feat: remove nativets in favor of bun with native pragma 2024-07-29 19:20:00 +02:00
HugoCasa 6fb0c4171e feat: add support for text/plain webhook (#4146) 2024-07-29 15:56:25 +02:00
Ruben Fiszel 43f5f31126 improve slightly concurrency run min started_at query 2024-07-27 12:41:01 +02:00
Ruben Fiszel 6df0b31d20 improve slightly concurrency run min started_at query 2024-07-27 12:28:55 +02:00
Ruben Fiszel c996261f05 chore: update sqlx to 0.8.0 2024-07-24 11:48:33 +02:00
HugoCasa 609e5d00eb feat: apply workspace specific tags only to some workspaces (#4107) 2024-07-23 19:12:11 +02:00
Ruben Fiszel 7f2cbb40f6 feat: improve flow status viewer (show branch chosen + all iterations in for loop) (#4074)
* all

* all

* all

* all

* all
2024-07-13 18:53:24 +02:00
Ruben Fiszel 8f2fd8984f remove env_id default value 2024-07-11 09:00:56 +02:00
Ruben Fiszel a443368d41 specialize soft cancel filter 2024-07-11 01:27:56 +02:00
Ruben Fiszel e6e08108a6 fix: improve handling of schedules with retries and concurrency limits 2024-07-05 20:37:30 +02:00
Ruben Fiszel b7b83a7d42 fix: improve dedicated workers for flows 2024-07-04 18:12:59 +02:00
Ruben Fiszel 2812792326 fix: memory optimization for flow with big args (#4019) 2024-07-04 10:08:42 +02:00
HugoCasa 7f2289d4d5 feat: flow versioning (#4009)
* feat: flow versioning

* fix: sqlx

* fix: update schedule test for flow versioning

* fix: with_deployment_msg + UI nits

* fix: nit

* fix: improve down migration

* patch: keep latest flow version in flow table for backward compat

* fix: app deployments in list view

* chore: update ee ref

* fix: merge

* fix: tests
2024-07-03 15:53:45 +02:00
HugoCasa 5e23cc26d0 fix: improve flow cancellation (#4013)
* fix: improve flow cancellation

* fix: sqlx

* fix: cancel shortcut when no parent and not running
2024-07-03 14:50:52 +02:00
HugoCasa ec673ac6b4 feat: schedule pausing (#3976)
* feat: schedule pausing

* fix: improve UI
2024-06-25 23:39:34 +02:00
Ruben Fiszel f41972d085 add timeout for cancel jobs (#3941) 2024-06-20 21:22:44 +02:00
Ruben Fiszel afd74183c9 nit cancel improvement 2024-06-20 13:16:28 +02:00
Ruben Fiszel 41739414b1 use auto-complete for worker group select 2024-06-19 13:50:21 +02:00
wendrul 88149e4fe0 Implement PushArgs from cloudevents+json (#3927)
* Implement PushArgs from cloudevents+json

* Remove incomplete batching, overwrite metadata

Overwrite metadata to make it available as a script parameter if
present.
2024-06-18 22:13:32 +02:00
Ruben Fiszel 91edb521e8 fix: fix workflow as code 2024-06-17 05:37:57 +02:00
HugoCasa eabdebe1dc fix: job perms for agent mode (#3911) 2024-06-14 17:36:10 +02:00
HugoCasa 93f58056a0 feat: replace ephemeral tokens by jwt (#3908)
* feat: replace ephemeral tokens by jwt

* fix: migration + sqlx

* fix: tests, agent, ee ref

* fix: sqlx

* fix: tests

* fix: jwt prefix change + fix tests

* fix: nit

* fix: handle agent mode
2024-06-14 13:07:35 +02:00
Ruben Fiszel 5cb2c9d1f7 feat(cli): add wmill flow generate-locks 2024-06-10 11:44:53 +02:00
Ruben Fiszel c8915063c4 feat: track dependency map for bun + inline script of flows 2024-06-08 16:43:48 +02:00
Ruben Fiszel e666f837cd fix: further restrict job api to logged in workspace users or anonymous jobs only" (#3860) 2024-06-03 15:13:15 +02:00
Ruben Fiszel a4d4213f2f fix compile issue 2024-05-31 12:30:58 +02:00
Ruben Fiszel 1947abddd4 fix: remove quotes around interpolated arg values of tags 2024-05-28 16:56:27 +02:00
Ruben Fiszel 99edb54362 set last_ping to null when requeuing because of concurrency limits 2024-05-27 15:53:32 +02:00
Ruben Fiszel 1dfe4bf9fa increase min re-scheduling 2024-05-26 05:20:11 +02:00
Ruben Fiszel 9d2e4df920 reschedule to at least 1secs in future 2024-05-26 05:04:42 +02:00
Ruben Fiszel 6a332bc30f fix: make all error strings more verbose 2024-05-25 22:15:15 +02:00
Ruben Fiszel 218ea8ce3e nit improvements for concurrency jobs 2024-05-25 17:28:32 +02:00
Ruben Fiszel 4d3efb8066 nit improvements for concurrency jobs 2024-05-25 17:26:08 +02:00
Ruben Fiszel 699a43e665 fix: improve concurrency re-scheduling at scale 2024-05-25 17:20:11 +02:00
Ruben Fiszel e207c1d77d fix: improve concurrency re-scheduling at scale 2024-05-25 15:56:56 +02:00
HugoCasa 92cf325c35 fix: use hub script language as tag instead of 'hub' (#3816)
* fix: use hub script language as tag instead of 'hub'

* fix: remove hub tag
2024-05-25 10:38:03 +02:00
Ruben Fiszel 4f30b1fb82 feat: store failed_retries per module state and display failed retries in flow status viewer 2024-05-23 19:16:26 +02:00
HugoCasa 126459f972 feat: improve permissioned audit logs (#3799)
* fix: increase token label size in db

* Revert "Revert "feat:  improve premissioned audit logs (#3793)" (#3798)"

This reverts commit afae33f5f8.

* feat: add username to email function

* fix: nit

* fix: add docstring to global func
2024-05-23 17:23:50 +02:00
Ruben Fiszel afae33f5f8 Revert "feat: improve premissioned audit logs (#3793)" (#3798)
This reverts commit 35f8eecf2d.
2024-05-23 11:12:51 +02:00
HugoCasa 35f8eecf2d feat: improve premissioned audit logs (#3793)
* feat:  improve premissioned audit logs

* chore: update ee ref

* fix: build

* fix: sqlx
2024-05-23 08:55:48 +02:00
Ruben Fiszel 868c5254d5 fix: improve concurrency key migration 2024-05-21 12:18:05 +02:00
Ruben Fiszel c43d04b95d feat: reduce memory usage (#3768)
* all

* all

* optimize deserialize

* all

* all

* fix issue

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile

* fix compile
2024-05-19 21:58:38 +02:00
Ruben Fiszel d5fc26ac82 fix: fix args interpolation for tag and concurrency key for non string values 2024-05-17 00:27:38 +02:00
Ruben Fiszel e014deaf8a fix: improve support for non existing key in concurrency_key table 2024-05-16 23:43:30 +02:00
HugoCasa e8bdff5f1a fix(backend): prevent immediate cancellation of the error handler when a job is forcibly cancelled (#3751) 2024-05-16 16:53:27 +02:00
wendrul 60b036c1ae Add concurrency limits observability (#3586)
* Add concurrency_key table and field to payload

Add a new table custom_concurrency_key for storing concurrency keys on a
per job basis. Add the field to the job payload to populate the table on
creation of a new job.

* Rename to custom_concurrency_key

Be more explicit about the nature of the option variable by calling it
a more appropriate name.

* Delete concurrency_keys on delete_expire_items

* Propagate db errors up

* Add ref to EE changes

* update sqlx

* Add concurrency_key to tests

* Revert renaming of FlowValue field

FlowValue field concurrency_key must be named concurrency_key for
serialization purposes.

* Remove debug print statement

* Get concurrency_key from Job

Whether it is a Completed job or a queued one, add a ways to get the
associated concurrency key

* Add endpoint to get concurrency_key

* Add endpoint and button to get job concurrency_key

Add a line with a link on the FlowMetadata that goes to the
concurrency_groups page. add endpoint to get the concurrency_key of a
job

* Merge concurrency_key tables into one

migration + change all related querrys

* Add concurrency plot to the runs page

* Prepare sqlx

* Add concurrency Key filter on UI

* Prepare sqlx

* Prepare sqlx

* Fix filter and order query

The limit makes more sense if we cut the older rows, so order by
started_at

* Factor interpolation to reuse on concurrency key

Factor the arg interpolation logic into a function and finish the
processing of concurrency key before insertion

* Remove old concurrency key processing logic

* Second transaction with userdb

To send all concurrency intervals but revealing only uuids of accessible
jobs, make a second transaction with the userdb.

* Remove old second endpoint

the intervals endpoint now also gets the concurrencyt key information
for all jobs

* Show external jobs

* Put filters into a dropdown

Create a ToggleButtonMore and put elements into a dropdown

* Add toggle between two graphs

* Add filter functionality to concurrency graph

* Improve concurrency graph front

* Fix concurrency groups page

* Prepare sqlx

* Add ref to ee

* Change migration to create new table instead

Instead of renaming the custom_concurrency_key_ended atble, we create a
new table and we will delete custom_concurrency_key_ended in the future
when it is no longer linked to any jobs

* Do small UI improvements

* Fix range fusion by not filtering past jobs

Instead of filtering jobs in the backend on a startedAfter value, limit
the query to 1000 and query all possible towards the past to get a good
context for the graph in most sane situations

* Improve frontend UI
2024-05-15 20:15:14 +02:00