Compare commits

...

5 Commits

Author SHA1 Message Date
snyk-bot
af81f1425f fix: Dockerfile to reduce vulnerabilities
The following vulnerabilities are fixed with an upgrade:
- https://snyk.io/vuln/SNYK-DEBIAN12-ZLIB-6008963
- https://snyk.io/vuln/SNYK-DEBIAN12-KRB5-1549480
- https://snyk.io/vuln/SNYK-DEBIAN12-KRB5-6277411
- https://snyk.io/vuln/SNYK-DEBIAN12-KRB5-6277412
- https://snyk.io/vuln/SNYK-DEBIAN12-SYSTEMD-1560739
2024-12-31 05:50:49 +00:00
Lucas Abel
eeece84a4b fix: handle 'flownode' job kind where missing (#4990) 2024-12-30 19:10:47 +09:00
Ruben Fiszel
6bcdde927c chore(main): release 1.441.2 (#4987)
* chore(main): release 1.441.2

* Apply automatic changes

---------

Co-authored-by: rubenfiszel <rubenfiszel@users.noreply.github.com>
2024-12-27 16:37:20 +01:00
Alexander Petric
51f5197bc8 fix lsp critical vulnerabilities (#4988)
* fix critical vulnerabilities lsp

* formatting

* fix only vulns
2024-12-27 23:50:28 +09:00
Lucas Abel
8db69ce15e fix(backend): fix zombies left by the bash executor (#4985) 2024-12-27 14:23:05 +01:00
25 changed files with 259 additions and 156 deletions

View File

@@ -1,5 +1,12 @@
# Changelog
## [1.441.2](https://github.com/windmill-labs/windmill/compare/v1.441.1...v1.441.2) (2024-12-27)
### Bug Fixes
* **backend:** fix zombies left by the bash executor ([#4985](https://github.com/windmill-labs/windmill/issues/4985)) ([8db69ce](https://github.com/windmill-labs/windmill/commit/8db69ce15e25601d0ac2ac98b1e45c0c01c11967))
## [1.441.1](https://github.com/windmill-labs/windmill/compare/v1.441.0...v1.441.1) (2024-12-24)

View File

@@ -1,6 +1,6 @@
ARG DEBIAN_IMAGE=debian:bookworm-slim
ARG RUST_IMAGE=rust:1.82-slim-bookworm
ARG PYTHON_IMAGE=python:3.11.10-slim-bookworm
ARG PYTHON_IMAGE=python:3.14.0a3-slim-bookworm
FROM ${RUST_IMAGE} AS rust_base

View File

@@ -0,0 +1,25 @@
{
"db_name": "PostgreSQL",
"query": "\n UPDATE queue SET flow_status = JSONB_SET(flow_status, ARRAY['user_states'], JSONB_SET(COALESCE(flow_status->'user_states', '{}'::jsonb), ARRAY[$1], $2))\n WHERE id = $3 AND workspace_id = $4 AND job_kind IN ('flow', 'flowpreview', 'flownode') RETURNING 1\n ",
"describe": {
"columns": [
{
"ordinal": 0,
"name": "?column?",
"type_info": "Int4"
}
],
"parameters": {
"Left": [
"Text",
"Jsonb",
"Uuid",
"Text"
]
},
"nullable": [
null
]
},
"hash": "364248db86a9228bba6ff522e811d68c5c902ee0a07ea69bff772ff10d0dc5aa"
}

View File

@@ -0,0 +1,34 @@
{
"db_name": "PostgreSQL",
"query": "UPDATE queue SET running = false, started_at = null\n WHERE last_ping < now() - ($1 || ' seconds')::interval\n AND running = true AND job_kind NOT IN ('flow', 'flowpreview', 'flownode', 'singlescriptflow') AND same_worker = false RETURNING id, workspace_id, last_ping",
"describe": {
"columns": [
{
"ordinal": 0,
"name": "id",
"type_info": "Uuid"
},
{
"ordinal": 1,
"name": "workspace_id",
"type_info": "Varchar"
},
{
"ordinal": 2,
"name": "last_ping",
"type_info": "Timestamptz"
}
],
"parameters": {
"Left": [
"Text"
]
},
"nullable": [
false,
false,
true
]
},
"hash": "84576f6add15108ade2ed3a88185d67db17904859e5f01f1d578af4e1d062a85"
}

View File

@@ -0,0 +1,28 @@
{
"db_name": "PostgreSQL",
"query": "\n SELECT usr.email, usage.executions\n FROM usr\n , LATERAL (\n SELECT COALESCE(SUM(duration_ms + 1000)/1000 , 0)::BIGINT executions\n FROM completed_job\n WHERE workspace_id = $1\n AND job_kind NOT IN ('flow', 'flowpreview', 'flownode')\n AND email = usr.email\n AND now() - '1 week'::interval < created_at \n ) usage\n WHERE workspace_id = $1\n ",
"describe": {
"columns": [
{
"ordinal": 0,
"name": "email",
"type_info": "Varchar"
},
{
"ordinal": 1,
"name": "executions",
"type_info": "Int8"
}
],
"parameters": {
"Left": [
"Text"
]
},
"nullable": [
false,
null
]
},
"hash": "f6a275ad8bc7dfec7f9a6b60c669f6f2ff93ce57b5afadabd618e1fb52951fef"
}

248
backend/Cargo.lock generated
View File

@@ -441,7 +441,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -501,7 +501,7 @@ checksum = "3b43422f69d8ff38f95f1b2bb76517c91589a924d1559a0e935d7c8ce0274c11"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -523,7 +523,7 @@ checksum = "c7c24de15d275a1ecfd47a380fb4d5ec9bfe0933f309ed5e705b775596a3574d"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -559,7 +559,7 @@ checksum = "721cae7de5c34fbb2acd27e21e6d2cf7b886dce0c27388d46c4e6c47ea4318dd"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -771,9 +771,9 @@ dependencies = [
[[package]]
name = "aws-smithy-async"
version = "1.2.2"
version = "1.2.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8aa8ff1492fd9fb99ae28e8467af0dbbb7c31512b16fabf1a0f10d7bb6ef78bb"
checksum = "427cb637d15d63d6f9aae26358e1c9a9c09d5aa490d64b09354c8217cfef0f28"
dependencies = [
"futures-util",
"pin-project-lite",
@@ -821,9 +821,9 @@ dependencies = [
[[package]]
name = "aws-smithy-runtime"
version = "1.7.5"
version = "1.7.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "431a10d0e07e09091284ef04453dae4069283aa108d209974d67e77ae1caa658"
checksum = "a05dd41a70fc74051758ee75b5c4db2c0ca070ed9229c3df50e9475cda1cb985"
dependencies = [
"aws-smithy-async",
"aws-smithy-http",
@@ -865,9 +865,9 @@ dependencies = [
[[package]]
name = "aws-smithy-types"
version = "1.2.10"
version = "1.2.11"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8ecbf4d5dfb169812e2b240a4350f15ad3c6b03a54074e5712818801615f2dc5"
checksum = "38ddc9bd6c28aeb303477170ddd183760a956a03e083b3902a990238a7e3792d"
dependencies = [
"base64-simd 0.8.0",
"bytes",
@@ -1099,7 +1099,7 @@ dependencies = [
"regex",
"rustc-hash 1.1.0",
"shlex",
"syn 2.0.91",
"syn 2.0.92",
"which 4.4.2",
]
@@ -1120,7 +1120,7 @@ dependencies = [
"regex",
"rustc-hash 1.1.0",
"shlex",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -1138,7 +1138,7 @@ dependencies = [
"regex",
"rustc-hash 2.1.0",
"shlex",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -1313,7 +1313,7 @@ dependencies = [
"proc-macro-crate",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -1415,7 +1415,7 @@ checksum = "3fa76293b4f7bb636ab88fd78228235b5248b4d05cc589aed610f954af5d7c7a"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -1530,9 +1530,9 @@ dependencies = [
[[package]]
name = "cc"
version = "1.2.5"
version = "1.2.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c31a0499c1dc64f458ad13872de75c0eb7e3fdb0e67964610c914b034fc5956e"
checksum = "8d6dbb628b8f8555f86d0323c2eb39e3ec81901f4b83e091db8a6a76d316a333"
dependencies = [
"jobserver",
"libc",
@@ -1675,7 +1675,7 @@ dependencies = [
"heck 0.5.0",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -1913,13 +1913,13 @@ dependencies = [
[[package]]
name = "cron"
version = "0.13.0"
version = "0.14.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "eee8b2b4516038bc0f1d3c9934bcb4a13dd316e04abbc63c96757a6d75978532"
checksum = "dbe58904b68d95ad2c69a2e9607ffc70ce196c1910f83a340029c1448e06ed65"
dependencies = [
"chrono",
"nom",
"once_cell",
"winnow 0.6.20",
]
[[package]]
@@ -2060,7 +2060,7 @@ checksum = "f46882e17999c6cc590af592290432be3bce0428cb0d5f8b6715e4dc7b383eb3"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -2108,7 +2108,7 @@ dependencies = [
"proc-macro2",
"quote",
"strsim 0.11.1",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -2130,7 +2130,7 @@ checksum = "d336a2a514f6ccccaa3e09b02d41d35330c07ddf03a62165fcec10bb561c7806"
dependencies = [
"darling_core 0.20.10",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -2657,7 +2657,7 @@ dependencies = [
"stringcase",
"strum 0.25.0",
"strum_macros 0.25.3",
"syn 2.0.91",
"syn 2.0.92",
"thiserror 1.0.69",
]
@@ -2843,7 +2843,7 @@ dependencies = [
"proc-macro2",
"quote",
"rustc_version 0.4.1",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -2948,7 +2948,7 @@ checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -2971,7 +2971,7 @@ checksum = "f2b99bf03862d7f545ebc28ddd33a665b50865f4dfd84031a393823879bd4c54"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3127,7 +3127,7 @@ dependencies = [
"heck 0.5.0",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3147,7 +3147,7 @@ checksum = "de0d48a183585823424a4ce1aa132d174a6a81bd540895822eb4c8373a8e49e8"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3352,7 +3352,7 @@ checksum = "32016f1242eb82af5474752d00fd8ebcd9004bd69b462b1c91de833972d08ed4"
dependencies = [
"proc-macro2",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3384,7 +3384,7 @@ checksum = "e99b8b3c28ae0e84b604c75f721c21dc77afb3706076af5e8216d15fd1deaae3"
dependencies = [
"frunk_proc_macro_helpers",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3396,7 +3396,7 @@ dependencies = [
"frunk_core",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3408,7 +3408,7 @@ dependencies = [
"frunk_core",
"frunk_proc_macro_helpers",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3532,7 +3532,7 @@ checksum = "162ee34ebcb7c64a8abebc059ce0fee27c2262618d7b60ed8faf72fef13c3650"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -3785,7 +3785,7 @@ checksum = "53010ccb100b96a67bc32c0175f0ed1426b31b655d562898e57325f81c023ac0"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -4502,7 +4502,7 @@ checksum = "1ec89e9337638ecdc08744df490b221a7399bf8d164eb52a665454e60e075ad6"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -4624,7 +4624,7 @@ dependencies = [
"heck 0.5.0",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -5268,7 +5268,7 @@ checksum = "a7ce64b975ed4f123575d11afd9491f2e37bbd5813fbfbc0f09ae1fbddea74e0"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -5307,7 +5307,7 @@ dependencies = [
"proc-macro-error2",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
"termcolor",
"thiserror 1.0.69",
]
@@ -5564,7 +5564,7 @@ dependencies = [
"proc-macro-crate",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -5737,7 +5737,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6099,7 +6099,7 @@ dependencies = [
"phf_shared",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6140,7 +6140,7 @@ checksum = "3c0f5fad0874fc7abcd4d750e76917eaebbecaa2c20bde22e1dbeeba8beb758c"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6274,7 +6274,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "64d1ec885c64d0457d564db4ec299b2dae3f9c02808b8ad9c3a089c591b18033"
dependencies = [
"proc-macro2",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6314,7 +6314,7 @@ dependencies = [
"proc-macro-error-attr2",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6325,7 +6325,7 @@ checksum = "07c277e4e643ef00c1233393c673f655e3672cf7eb3ba08a00bdd0ea59139b5f"
dependencies = [
"proc-macro-rules-macros",
"proc-macro2",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6337,7 +6337,7 @@ dependencies = [
"once_cell",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6398,7 +6398,7 @@ dependencies = [
"schemars",
"serde",
"serde_json",
"syn 2.0.91",
"syn 2.0.92",
"thiserror 1.0.69",
"typify",
"unicode-ident",
@@ -6418,7 +6418,7 @@ dependencies = [
"serde_json",
"serde_tokenstream",
"serde_yaml",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6471,7 +6471,7 @@ dependencies = [
"itertools 0.12.1",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6484,7 +6484,7 @@ dependencies = [
"itertools 0.13.0",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -6641,9 +6641,9 @@ dependencies = [
[[package]]
name = "quote"
version = "1.0.37"
version = "1.0.38"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b5b9d34b8991d19d98081b46eacdd8eb58c6f2b201139f7c5f643cc155a633af"
checksum = "0e4dccaaaf89514f546c693ddc140f729f958c247918a13380cccc6078391acc"
dependencies = [
"proc-macro2",
]
@@ -7137,7 +7137,7 @@ dependencies = [
"quote",
"rust-embed-utils",
"shellexpand",
"syn 2.0.91",
"syn 2.0.92",
"walkdir",
]
@@ -7423,9 +7423,9 @@ dependencies = [
[[package]]
name = "rustversion"
version = "1.0.18"
version = "1.0.19"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0e819f2bc632f285be6d7cd36e25940d45b2391dd6d9b939e79de557f7014248"
checksum = "f7c45b9784283f1b2e7fb61b42047c2fd678ef0960d4f6f1eba131594cc369d4"
[[package]]
name = "ryu"
@@ -7523,7 +7523,7 @@ dependencies = [
"proc-macro2",
"quote",
"serde_derive_internals",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -7683,7 +7683,7 @@ checksum = "46f859dbbf73865c6627ed570e78961cd3ac92407a2d117204c49232485da55e"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -7694,7 +7694,7 @@ checksum = "18d26a20a969b9e3fdf2fc2d9f21eda6c40e2de84c9408bb5d3b05d499aae711"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -7759,7 +7759,7 @@ checksum = "6c64451ba24fc7a6a2d60fc75dd9c83c90903b19028d4eff35e88fc1e86564e9"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -7780,7 +7780,7 @@ dependencies = [
"proc-macro2",
"quote",
"serde",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -7810,9 +7810,9 @@ dependencies = [
[[package]]
name = "serde_with"
version = "3.11.0"
version = "3.12.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8e28bdad6db2b8340e449f7108f020b3b092e8583a9e3fb82713e1d4e71fe817"
checksum = "d6b6f7f2fcb69f747921f79f3926bd1e203fce4fef62c268dd3abfb6d86029aa"
dependencies = [
"base64 0.22.1",
"chrono",
@@ -7828,14 +7828,14 @@ dependencies = [
[[package]]
name = "serde_with_macros"
version = "3.11.0"
version = "3.12.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9d846214a9854ef724f3da161b426242d8de7c1fc7de2f89bb1efcb154dca79d"
checksum = "8d00caa5193a3c8362ac2b73be6b9e768aa5a4b2f721d8f4b339600c3cb51f8e"
dependencies = [
"darling 0.20.10",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8177,7 +8177,7 @@ checksum = "01b2e185515564f15375f593fb966b5718bc624ba77fe49fa4616ad619690554"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8248,7 +8248,7 @@ dependencies = [
"quote",
"sqlx-core",
"sqlx-macros-core",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8271,7 +8271,7 @@ dependencies = [
"sqlx-mysql",
"sqlx-postgres",
"sqlx-sqlite",
"syn 2.0.91",
"syn 2.0.92",
"tempfile",
"tokio",
"url",
@@ -8423,7 +8423,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8483,7 +8483,7 @@ dependencies = [
"proc-macro2",
"quote",
"rustversion",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8496,7 +8496,7 @@ dependencies = [
"proc-macro2",
"quote",
"rustversion",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8604,7 +8604,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8653,7 +8653,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8738,7 +8738,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8845,7 +8845,7 @@ checksum = "63db0adcff29d220c3d151c5b25c0eabe7e32dd936212b84cdaa1392e3130497"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8856,7 +8856,7 @@ checksum = "f486687bfb7b5c560868f69ed2d458b880cebc9babebcb67e49f31b55c5bf847"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8879,7 +8879,7 @@ dependencies = [
"proc-macro2",
"quote",
"swc_macros_common",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -8895,9 +8895,9 @@ dependencies = [
[[package]]
name = "syn"
version = "2.0.91"
version = "2.0.92"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d53cbcb5a243bd33b7858b1d7f4aca2153490815872d86d955d6ea29f743c035"
checksum = "70ae51629bf965c5c098cc9e87908a3df5301051a9e087d6f9bef5c9771ed126"
dependencies = [
"proc-macro2",
"quote",
@@ -8927,7 +8927,7 @@ checksum = "c8af7666ab7b6390ab78131fb5b0fce11d6b7a6951602017c35fa82800708971"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -9201,7 +9201,7 @@ checksum = "4fee6c4efc90059e10f81e6d42c60a18f76588c3d74cb83a0b242a2b6c7504c1"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -9212,7 +9212,7 @@ checksum = "7b50fa271071aae2e6ee85f842e2e28ba8cd2c5fb67f11fcb1fd70b276f9e7d4"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -9447,7 +9447,7 @@ checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -9795,7 +9795,7 @@ checksum = "395ae124c09f9e6918a2310af6038fba074bcf474ac352496d5910dd59a2226d"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -10029,7 +10029,7 @@ dependencies = [
"regress",
"schemars",
"serde_json",
"syn 2.0.91",
"syn 2.0.92",
"thiserror 1.0.69",
"unicode-ident",
]
@@ -10046,7 +10046,7 @@ dependencies = [
"serde",
"serde_json",
"serde_tokenstream",
"syn 2.0.91",
"syn 2.0.92",
"typify-impl",
]
@@ -10128,9 +10128,9 @@ dependencies = [
[[package]]
name = "unicase"
version = "2.8.0"
version = "2.8.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7e51b68083f157f853b6379db119d1c1be0e6e4dec98101079dec41f6f5cf6df"
checksum = "75b844d17643ee918803943289730bec8aac480150456169e647ed0b576ba539"
[[package]]
name = "unicode-bidi"
@@ -10453,7 +10453,7 @@ dependencies = [
"once_cell",
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
"wasm-bindgen-shared",
]
@@ -10487,7 +10487,7 @@ checksum = "e94f17b526d0a461a191c78ea52bbce64071ed5c04c9ffe424dcb38f74171bb7"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
"wasm-bindgen-backend",
"wasm-bindgen-shared",
]
@@ -10520,7 +10520,7 @@ checksum = "b7f89739351a2e03cb94beb799d47fb2cac01759b40ec441f7de39b00cbf7ef0"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -10657,7 +10657,7 @@ checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
[[package]]
name = "windmill"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"axum",
@@ -10698,7 +10698,7 @@ dependencies = [
[[package]]
name = "windmill-api"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"argon2",
@@ -10783,7 +10783,7 @@ dependencies = [
[[package]]
name = "windmill-api-client"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"base64 0.22.1",
"chrono",
@@ -10801,7 +10801,7 @@ dependencies = [
[[package]]
name = "windmill-audit"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"chrono",
"serde",
@@ -10814,7 +10814,7 @@ dependencies = [
[[package]]
name = "windmill-autoscaling"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"serde",
@@ -10828,7 +10828,7 @@ dependencies = [
[[package]]
name = "windmill-common"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"async-stream",
@@ -10887,7 +10887,7 @@ dependencies = [
[[package]]
name = "windmill-git-sync"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"regex",
"serde",
@@ -10901,7 +10901,7 @@ dependencies = [
[[package]]
name = "windmill-indexer"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"bytes",
@@ -10924,19 +10924,19 @@ dependencies = [
[[package]]
name = "windmill-macros"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"itertools 0.13.0",
"lazy_static",
"proc-macro2",
"quote",
"regex",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
name = "windmill-parser"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"convert_case 0.6.0",
"serde",
@@ -10945,7 +10945,7 @@ dependencies = [
[[package]]
name = "windmill-parser-bash"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"lazy_static",
@@ -10957,7 +10957,7 @@ dependencies = [
[[package]]
name = "windmill-parser-csharp"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"serde_json",
@@ -10969,7 +10969,7 @@ dependencies = [
[[package]]
name = "windmill-parser-go"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"gosyn",
@@ -10981,7 +10981,7 @@ dependencies = [
[[package]]
name = "windmill-parser-graphql"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"lazy_static",
@@ -10993,7 +10993,7 @@ dependencies = [
[[package]]
name = "windmill-parser-php"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"itertools 0.13.0",
@@ -11004,7 +11004,7 @@ dependencies = [
[[package]]
name = "windmill-parser-py"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"itertools 0.13.0",
@@ -11015,7 +11015,7 @@ dependencies = [
[[package]]
name = "windmill-parser-py-imports"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"async-recursion",
@@ -11033,7 +11033,7 @@ dependencies = [
[[package]]
name = "windmill-parser-rust"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"convert_case 0.6.0",
@@ -11043,14 +11043,14 @@ dependencies = [
"quote",
"regex",
"serde_json",
"syn 2.0.91",
"syn 2.0.92",
"toml 0.7.8",
"windmill-parser",
]
[[package]]
name = "windmill-parser-sql"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"lazy_static",
@@ -11062,7 +11062,7 @@ dependencies = [
[[package]]
name = "windmill-parser-ts"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"lazy_static",
@@ -11080,7 +11080,7 @@ dependencies = [
[[package]]
name = "windmill-parser-wasm"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"getrandom 0.2.15",
@@ -11102,7 +11102,7 @@ dependencies = [
[[package]]
name = "windmill-parser-yaml"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"serde_json",
@@ -11112,7 +11112,7 @@ dependencies = [
[[package]]
name = "windmill-queue"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"async-recursion",
@@ -11146,7 +11146,7 @@ dependencies = [
[[package]]
name = "windmill-sql-datatype-parser-wasm"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"wasm-bindgen",
"wasm-bindgen-test",
@@ -11156,7 +11156,7 @@ dependencies = [
[[package]]
name = "windmill-worker"
version = "1.441.1"
version = "1.441.2"
dependencies = [
"anyhow",
"async-recursion",
@@ -11535,7 +11535,7 @@ checksum = "2380878cad4ac9aac1e2435f3eb4020e8374b5f13c296cb75b4620ff8e229154"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
"synstructure",
]
@@ -11557,7 +11557,7 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]
@@ -11577,7 +11577,7 @@ checksum = "595eed982f7d355beb85837f651fa22e90b3c044842dc7f2c2842c086f295808"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
"synstructure",
]
@@ -11606,7 +11606,7 @@ checksum = "6eafa6dfb17584ea3e2bd6e76e0cc15ad7af12b09abdd1ca55961bed9b1063c6"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.91",
"syn 2.0.92",
]
[[package]]

View File

@@ -1,6 +1,6 @@
[package]
name = "windmill"
version = "1.441.1"
version = "1.441.2"
authors.workspace = true
edition.workspace = true
@@ -30,7 +30,7 @@ members = [
]
[workspace.package]
version = "1.441.1"
version = "1.441.2"
authors = ["Ruben Fiszel <ruben@windmill.dev>"]
edition = "2021"

View File

@@ -1497,7 +1497,7 @@ async fn handle_zombie_jobs(db: &Pool<Postgres>, base_internal_url: &str, worker
let restarted = sqlx::query!(
"UPDATE queue SET running = false, started_at = null
WHERE last_ping < now() - ($1 || ' seconds')::interval
AND running = true AND job_kind NOT IN ('flow', 'flowpreview', 'singlescriptflow') AND same_worker = false RETURNING id, workspace_id, last_ping",
AND running = true AND job_kind NOT IN ('flow', 'flowpreview', 'flownode', 'singlescriptflow') AND same_worker = false RETURNING id, workspace_id, last_ping",
*ZOMBIE_JOB_TIMEOUT,
)
.fetch_all(db)
@@ -1534,7 +1534,7 @@ async fn handle_zombie_jobs(db: &Pool<Postgres>, base_internal_url: &str, worker
let mut timeout_query =
"SELECT * FROM queue WHERE last_ping < now() - ($1 || ' seconds')::interval
AND running = true AND job_kind NOT IN ('flow', 'flowpreview', 'singlescriptflow')"
AND running = true AND job_kind NOT IN ('flow', 'flowpreview', 'flownode', 'singlescriptflow')"
.to_string();
if *RESTART_ZOMBIE_JOBS {
timeout_query.push_str(" AND same_worker = true");
@@ -1618,7 +1618,7 @@ async fn handle_zombie_flows(db: &DB) -> error::Result<()> {
r#"
SELECT *
FROM queue
WHERE running = true AND suspend = 0 AND suspend_until IS null AND scheduled_for <= now() AND (job_kind = 'flow' OR job_kind = 'flowpreview')
WHERE running = true AND suspend = 0 AND suspend_until IS null AND scheduled_for <= now() AND (job_kind = 'flow' OR job_kind = 'flowpreview' OR job_kind = 'flownode')
AND last_ping IS NOT NULL AND last_ping < NOW() - ($1 || ' seconds')::interval AND canceled = false
"#,
).bind(FLOW_ZOMBIE_TRANSITION_TIMEOUT.as_str())

View File

@@ -1,7 +1,7 @@
openapi: "3.0.3"
info:
version: 1.441.1
version: 1.441.2
title: Windmill API
contact:

View File

@@ -2340,7 +2340,7 @@ pub async fn set_flow_user_state(
let r = sqlx::query_scalar!(
r#"
UPDATE queue SET flow_status = JSONB_SET(flow_status, ARRAY['user_states'], JSONB_SET(COALESCE(flow_status->'user_states', '{}'::jsonb), ARRAY[$1], $2))
WHERE id = $3 AND workspace_id = $4 AND job_kind IN ('flow', 'flowpreview') RETURNING 1
WHERE id = $3 AND workspace_id = $4 AND job_kind IN ('flow', 'flowpreview', 'flownode') RETURNING 1
"#,
key,
value,

View File

@@ -473,7 +473,7 @@ async fn list_user_usage(
SELECT COALESCE(SUM(duration_ms + 1000)/1000 , 0)::BIGINT executions
FROM completed_job
WHERE workspace_id = $1
AND job_kind NOT IN ('flow', 'flowpreview')
AND job_kind NOT IN ('flow', 'flowpreview', 'flownode')
AND email = usr.email
AND now() - '1 week'::interval < created_at
) usage

View File

@@ -122,7 +122,7 @@ exit_status=$?
# Clean up the named pipe and background processes
rm -f bp
pkill -P $$ || true
# Exit with the captured status
exit $exit_status

View File

@@ -2,7 +2,7 @@ import { sleep } from "https://deno.land/x/sleep@v1.2.1/mod.ts";
import * as windmill from "https://deno.land/x/windmill@v1.174.0/mod.ts";
import * as api from "https://deno.land/x/windmill@v1.174.0/windmill-api/index.ts";
export const VERSION = "v1.441.1";
export const VERSION = "v1.441.2";
export async function login(email: string, password: string): Promise<string> {
return await windmill.UserService.login({

View File

@@ -60,7 +60,7 @@ export {
// }
// });
export const VERSION = "1.441.1";
export const VERSION = "1.441.2";
const command = new Command()
.name("wmill")

View File

@@ -1,12 +1,12 @@
{
"name": "windmill-components",
"version": "1.441.1",
"version": "1.441.2",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "windmill-components",
"version": "1.441.1",
"version": "1.441.2",
"license": "AGPL-3.0",
"dependencies": {
"@anthropic-ai/sdk": "^0.32.1",

View File

@@ -1,6 +1,6 @@
{
"name": "windmill-components",
"version": "1.441.1",
"version": "1.441.2",
"scripts": {
"dev": "vite dev",
"build": "vite build",

View File

@@ -1,9 +1,19 @@
FROM nikolaik/python-nodejs:python3.11-nodejs19-slim
FROM python:3.11-slim as python-base
FROM node:19-slim as node-base
FROM python-base
COPY --from=node-base /usr/local /usr/local
ENV PATH="/usr/local/bin:${PATH}"
RUN apt-get update \
&& apt-get install -y shellcheck
RUN yarn global add diagnostic-languageserver
RUN yarn global add pyright
&& apt-get install -y shellcheck wget \
&& apt-get clean \
&& rm -rf /var/lib/apt/lists/* \
&& pip install pipenv
RUN npm install -g diagnostic-languageserver pyright
RUN set -eux; \
arch="$(dpkg --print-architecture)"; arch="${arch##*-}"; \
url=; \
@@ -24,6 +34,7 @@ RUN set -eux; \
ENV PATH="${PATH}:/usr/local/go/bin"
ENV GOBIN=/usr/local/go/bin
RUN /usr/local/go/bin/go install -v golang.org/x/tools/gopls@latest
RUN pip3 install tornado python-lsp-jsonrpc ruff-lsp
COPY --from=denoland/deno:2.1.2 --chmod=755 /usr/bin/deno /usr/bin/deno
@@ -39,10 +50,8 @@ RUN pipenv install
COPY pyls_launcher.py .
RUN mkdir -p /tmp/monaco && chmod -R 777 /tmp/monaco
RUN cd /tmp/monaco && yarn add -D windmill-client
RUN cd /tmp/monaco && npm install --save-dev windmill-client
EXPOSE 3001
CMD ["python3" ,"pyls_launcher.py"]
CMD ["python3", "pyls_launcher.py"]

View File

@@ -4,8 +4,8 @@ verify_ssl = true
name = "pypi"
[packages]
wmill = ">=1.441.1"
wmill_pg = ">=1.441.1"
wmill = ">=1.441.2"
wmill_pg = ">=1.441.2"
sendgrid = "*"
mysql-connector-python = "*"
pymongo = "*"

View File

@@ -1,7 +1,7 @@
openapi: "3.0.3"
info:
version: 1.441.1
version: 1.441.2
title: OpenFlow Spec
contact:
name: Ruben Fiszel

View File

@@ -12,7 +12,7 @@
RootModule = 'WindmillClient.psm1'
# Version number of this module.
ModuleVersion = '1.441.1'
ModuleVersion = '1.441.2'
# Supported PSEditions
# CompatiblePSEditions = @()

View File

@@ -1,6 +1,6 @@
[tool.poetry]
name = "wmill"
version = "1.441.1"
version = "1.441.2"
description = "A client library for accessing Windmill server wrapping the Windmill client API"
license = "Apache-2.0"
homepage = "https://windmill.dev"

View File

@@ -1,6 +1,6 @@
[tool.poetry]
name = "wmill-pg"
version = "1.441.1"
version = "1.441.2"
description = "An extension client for the wmill client library focused on pg"
license = "Apache-2.0"
homepage = "https://windmill.dev"

View File

@@ -1,6 +1,6 @@
{
"name": "@windmill/windmill",
"version": "1.441.1",
"version": "1.441.2",
"exports": "./src/index.ts",
"publish": {
"exclude": ["!src", "./s3Types.ts", "./client.ts"]

View File

@@ -1,7 +1,7 @@
{
"name": "windmill-client",
"description": "Windmill SDK client for browsers and Node.js",
"version": "1.441.1",
"version": "1.441.2",
"author": "Ruben Fiszel",
"license": "Apache 2.0",
"devDependencies": {

View File

@@ -1 +1 @@
1.441.1
1.441.2