From 66a8927b53fe7b334aa11708577134afdd802140 Mon Sep 17 00:00:00 2001 From: Sergei Zaychenko Date: Fri, 6 Sep 2024 10:35:42 -0700 Subject: [PATCH] v0.35.0: kamu-cli v0.199.0 --- CHANGELOG.md | 9 + Cargo.lock | 543 ++++++++++++++++------------- Cargo.toml | 87 ++--- LICENSE.txt | 4 +- deny.toml | 6 +- src/app/api-server/Cargo.toml | 4 + src/app/api-server/src/app.rs | 30 +- src/app/api-server/src/database.rs | 17 +- 8 files changed, 386 insertions(+), 314 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 668c57bd..64b2b000 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,15 @@ All notable changes to this project will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). +## [0.35.0] - 2024-09-06 +### Changed +- Upgrade kamu-cli version to `0.199.0` + - Persistent Tasks & Flows + - Database schema breaking changes + - Get Data Panel: use SmTP for pull & push links + - GQL api method `setConfigCompaction` allows to set `metadataOnly` configuration for both root and derived datasets + - GQL api `triggerFlow` allows to trigger `HARD_COMPACTION` flow in `metadataOnly` mode for both root and derived datasets + ## [0.34.1] - 2024-08-30 ### Fixed - Critical errors were not logged due to logging guard destroyed before the call to tracing diff --git a/Cargo.lock b/Cargo.lock index 9978a16e..06e642f9 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -139,9 +139,9 @@ dependencies = [ [[package]] name = "alloy-chains" -version = "0.1.29" +version = "0.1.30" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bb07629a5d0645d29f68d2fb6f4d0cf15c89ec0965be915f303967180929743f" +checksum = "2b4f201b0ac8f81315fbdc55269965a8ddadbc04ab47fa65a1a468f9a40f7a5f" dependencies = [ "num_enum", "strum 0.26.3", @@ -409,7 +409,7 @@ checksum = "4d0f2d905ebd295e7effec65e5f6868d153936130ae718352771de3e7d03c75c" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -529,7 +529,7 @@ dependencies = [ "proc-macro-error", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -542,11 +542,11 @@ dependencies = [ "alloy-sol-macro-input", "const-hex", "heck 0.5.0", - "indexmap 2.4.0", + "indexmap 2.5.0", "proc-macro-error", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", "syn-solidity", "tiny-keccak", ] @@ -564,7 +564,7 @@ dependencies = [ "proc-macro2", "quote", "serde_json", - "syn 2.0.76", + "syn 2.0.77", "syn-solidity", ] @@ -1052,7 +1052,7 @@ dependencies = [ "arrow-schema", "chrono", "half", - "indexmap 2.4.0", + "indexmap 2.5.0", "lexical-core", "num", "serde", @@ -1181,7 +1181,7 @@ dependencies = [ "futures-util", "handlebars", "http 0.2.12", - "indexmap 2.4.0", + "indexmap 2.5.0", "mime", "multer", "num-traits", @@ -1228,7 +1228,7 @@ dependencies = [ "proc-macro2", "quote", "strum 0.25.0", - "syn 2.0.76", + "syn 2.0.77", "thiserror", ] @@ -1251,7 +1251,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "323a5143f5bdd2030f45e3f2e0c821c9b1d36e79cf382129c64299c50a7f3750" dependencies = [ "bytes", - "indexmap 2.4.0", + "indexmap 2.5.0", "serde", "serde_json", ] @@ -1264,7 +1264,7 @@ checksum = "3b43422f69d8ff38f95f1b2bb76517c91589a924d1559a0e935d7c8ce0274c11" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -1286,18 +1286,18 @@ checksum = "16e62a023e7c117e27523144c5d2459f4397fcc3cab0085af8e2224f643a0193" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "async-trait" -version = "0.1.81" +version = "0.1.82" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6e0c28dcc82d7c8ead5cb13beb15405b57b8546e93215673ff8ca0349a028107" +checksum = "a27b8a3a6e1a44fa4c8baf1f653e4172e81486d4941f2237e20dc2d0cf4ddff1" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -1343,7 +1343,7 @@ checksum = "3c87f3f15e7794432337fc718554eaa4dc8f04c9677a950ffe366f20a162ae42" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2026,9 +2026,9 @@ checksum = "c3ac9f8b63eca6fd385229b3675f6cc0dc5c8a5c8a54a59d4f52ffd670d87b0c" [[package]] name = "bytemuck" -version = "1.17.1" +version = "1.18.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "773d90827bc3feecfb67fab12e24de0749aad83c74b9504ecde46237b5cd24e2" +checksum = "94bbb0ad554ad961ddc5da507a12a29b14e4ae5bda06b19f575a3e6079d2e2ae" [[package]] name = "byteorder" @@ -2093,9 +2093,9 @@ dependencies = [ [[package]] name = "cc" -version = "1.1.15" +version = "1.1.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "57b6a275aa2903740dc87da01c62040406b8812552e97129a63ea8850a17c6e6" +checksum = "e9d013ecb737093c0e86b151a7b837993cf9ec6c502946cfb44bedc392421e0b" dependencies = [ "jobserver", "libc", @@ -2184,9 +2184,9 @@ dependencies = [ [[package]] name = "clap" -version = "4.5.16" +version = "4.5.17" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ed6719fffa43d0d87e5fd8caeab59be1554fb028cd30edc88fc4369b17971019" +checksum = "3e5a21b8495e732f1b3c364c9949b201ca7bae518c502c80256c96ad79eaf6ac" dependencies = [ "clap_builder", "clap_derive", @@ -2194,9 +2194,9 @@ dependencies = [ [[package]] name = "clap_builder" -version = "4.5.15" +version = "4.5.17" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "216aec2b177652e3846684cbfe25c9964d18ec45234f0f5da5157b207ed1aab6" +checksum = "8cf2dd12af7a047ad9d6da2b6b249759a22a7abc0f474c1dae1777afa4b21a73" dependencies = [ "anstream", "anstyle", @@ -2214,7 +2214,7 @@ dependencies = [ "heck 0.5.0", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2325,8 +2325,8 @@ checksum = "7c74b8349d32d297c9134b8c88677813a227df8f779daa29bfc29c183fe3dca6" [[package]] name = "container-runtime" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "cfg-if", @@ -2366,9 +2366,9 @@ checksum = "773648b94d0e5d620f64f280777445740e61fe701025087ec8b57f45c791888b" [[package]] name = "cpufeatures" -version = "0.2.13" +version = "0.2.14" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "51e852e6dc9a5bed1fae92dd2375037bf2b768725bf3be87811edee3249d09ad" +checksum = "608697df725056feaccfa42cffdaeeec3fccc4ffc38358ecd19b243e716a78e0" dependencies = [ "libc", ] @@ -2536,7 +2536,7 @@ checksum = "f46882e17999c6cc590af592290432be3bce0428cb0d5f8b6715e4dc7b383eb3" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2560,7 +2560,7 @@ dependencies = [ "proc-macro2", "quote", "strsim", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2571,7 +2571,7 @@ checksum = "d336a2a514f6ccccaa3e09b02d41d35330c07ddf03a62165fcec10bb561c7806" dependencies = [ "darling_core", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2589,9 +2589,9 @@ dependencies = [ [[package]] name = "dashmap" -version = "6.0.1" +version = "6.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "804c8821570c3f8b70230c2ba75ffa5c0f9a4189b9a432b6656c536712acae28" +checksum = "5041cc499144891f3790297212f32a74fb938e5136a14943f338ef9e0ae276cf" dependencies = [ "cfg-if", "crossbeam-utils", @@ -2609,8 +2609,8 @@ checksum = "e8566979429cf69b49a5c740c60791108e86440e8be149bbea4fe54d2c32d6e2" [[package]] name = "database-common" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "aws-config", @@ -2634,11 +2634,11 @@ dependencies = [ [[package]] name = "database-common-macros" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -2657,7 +2657,7 @@ dependencies = [ "bytes", "bzip2", "chrono", - "dashmap 6.0.1", + "dashmap 6.1.0", "datafusion-catalog", "datafusion-common", "datafusion-common-runtime", @@ -2676,7 +2676,7 @@ dependencies = [ "glob", "half", "hashbrown 0.14.5", - "indexmap 2.4.0", + "indexmap 2.5.0", "itertools 0.12.1", "log", "num_cpus", @@ -2749,7 +2749,7 @@ checksum = "799e70968c815b611116951e3dd876aef04bf217da31b72eec01ee6a959336a1" dependencies = [ "arrow", "chrono", - "dashmap 6.0.1", + "dashmap 6.1.0", "datafusion-common", "datafusion-expr", "futures", @@ -2856,7 +2856,7 @@ dependencies = [ "datafusion-expr", "datafusion-physical-expr", "hashbrown 0.14.5", - "indexmap 2.4.0", + "indexmap 2.5.0", "itertools 0.12.1", "log", "paste", @@ -2885,7 +2885,7 @@ dependencies = [ "half", "hashbrown 0.14.5", "hex", - "indexmap 2.4.0", + "indexmap 2.5.0", "itertools 0.12.1", "log", "paste", @@ -2943,7 +2943,7 @@ dependencies = [ "futures", "half", "hashbrown 0.14.5", - "indexmap 2.4.0", + "indexmap 2.5.0", "itertools 0.12.1", "log", "once_cell", @@ -3043,7 +3043,7 @@ dependencies = [ "proc-macro2", "quote", "rustc_version 0.4.1", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -3098,7 +3098,7 @@ checksum = "9d0e68e1e07d64dbf3bb2991657979ec4e3fe13b7b3c18067b802052af1330a3" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -3281,13 +3281,13 @@ dependencies = [ "heck 0.4.1", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "enum-variants" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" [[package]] name = "env_filter" @@ -3352,8 +3352,8 @@ dependencies = [ [[package]] name = "event-sourcing" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -3367,11 +3367,11 @@ dependencies = [ [[package]] name = "event-sourcing-macros" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -3605,7 +3605,7 @@ checksum = "87750cf4b7a4c0625b1529e4c543c2182106e4dedc60a2a6455e00d212c489ac" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -3716,7 +3716,7 @@ checksum = "d2fabcfbdc87f4758337ca535fb41a6d701b65693ce38287d856d1674551ec9b" [[package]] name = "graceful-shutdown" -version = "0.34.1" +version = "0.35.0" dependencies = [ "tokio", "tracing", @@ -3756,7 +3756,7 @@ dependencies = [ "futures-sink", "futures-util", "http 0.2.12", - "indexmap 2.4.0", + "indexmap 2.5.0", "slab", "tokio", "tokio-util", @@ -3775,7 +3775,7 @@ dependencies = [ "futures-core", "futures-sink", "http 1.1.0", - "indexmap 2.4.0", + "indexmap 2.5.0", "slab", "tokio", "tokio-util", @@ -4000,8 +4000,8 @@ dependencies = [ [[package]] name = "http-common" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "axum", "http 0.2.12", @@ -4097,21 +4097,21 @@ dependencies = [ [[package]] name = "hyper-rustls" -version = "0.27.2" +version = "0.27.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5ee4be2c948921a1a5320b629c4193916ed787a7f7f293fd3f7f5a6c9de74155" +checksum = "08afdbb5c31130e3034af566421053ab03787c640246a446327f550d11bcb333" dependencies = [ "futures-util", "http 1.1.0", "hyper 1.4.1", "hyper-util", "rustls 0.23.12", - "rustls-native-certs 0.7.3", + "rustls-native-certs 0.8.0", "rustls-pki-types", "tokio", "tokio-rustls 0.26.0", "tower-service", - "webpki-roots 0.26.3", + "webpki-roots 0.26.5", ] [[package]] @@ -4228,9 +4228,9 @@ dependencies = [ [[package]] name = "indexmap" -version = "2.4.0" +version = "2.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "93ead53efc7ea8ed3cfb0c79fc8023fbb782a5432b52830b6518941cebe6505c" +checksum = "68b900aa2f7301e21c36462b170ee99994de34dff39a4a6a528e80e7376d07e5" dependencies = [ "equivalent", "hashbrown 0.14.5", @@ -4284,8 +4284,8 @@ checksum = "8bb03732005da905c88227371639bf1ad885cc712789c011c31c5fb3ab3ccf02" [[package]] name = "internal-error" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "thiserror", ] @@ -4406,8 +4406,8 @@ dependencies = [ [[package]] name = "kamu" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-recursion", "async-stream", @@ -4422,7 +4422,7 @@ dependencies = [ "cfg-if", "chrono", "container-runtime", - "dashmap 6.0.1", + "dashmap 6.1.0", "datafusion", "digest 0.10.7", "dill", @@ -4477,8 +4477,8 @@ dependencies = [ [[package]] name = "kamu-accounts" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "base32", @@ -4504,8 +4504,8 @@ dependencies = [ [[package]] name = "kamu-accounts-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4521,8 +4521,8 @@ dependencies = [ [[package]] name = "kamu-accounts-postgres" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4539,8 +4539,8 @@ dependencies = [ [[package]] name = "kamu-accounts-services" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "argon2", "async-trait", @@ -4564,8 +4564,8 @@ dependencies = [ [[package]] name = "kamu-accounts-sqlite" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4582,8 +4582,8 @@ dependencies = [ [[package]] name = "kamu-adapter-auth-oso" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "dill", @@ -4598,13 +4598,13 @@ dependencies = [ [[package]] name = "kamu-adapter-flight-sql" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "arrow-flight", "async-trait", "base64 0.22.1", - "dashmap 6.0.1", + "dashmap 6.1.0", "datafusion", "futures", "like", @@ -4616,8 +4616,8 @@ dependencies = [ [[package]] name = "kamu-adapter-graphql" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-graphql", "async-trait", @@ -4651,8 +4651,8 @@ dependencies = [ [[package]] name = "kamu-adapter-http" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "aws-sdk-s3", @@ -4695,8 +4695,8 @@ dependencies = [ [[package]] name = "kamu-adapter-oauth" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4713,8 +4713,8 @@ dependencies = [ [[package]] name = "kamu-adapter-odata" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "axum", "chrono", @@ -4737,7 +4737,7 @@ dependencies = [ [[package]] name = "kamu-api-server" -version = "0.34.1" +version = "0.35.0" dependencies = [ "arrow-flight", "async-graphql", @@ -4782,6 +4782,7 @@ dependencies = [ "kamu-datasets-postgres", "kamu-datasets-services", "kamu-datasets-sqlite", + "kamu-flow-system", "kamu-flow-system-inmem", "kamu-flow-system-postgres", "kamu-flow-system-services", @@ -4789,8 +4790,11 @@ dependencies = [ "kamu-messaging-outbox-inmem", "kamu-messaging-outbox-postgres", "kamu-messaging-outbox-sqlite", + "kamu-task-system", "kamu-task-system-inmem", + "kamu-task-system-postgres", "kamu-task-system-services", + "kamu-task-system-sqlite", "messaging-outbox", "observability", "opendatafabric", @@ -4817,8 +4821,8 @@ dependencies = [ [[package]] name = "kamu-auth-rebac" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "internal-error", @@ -4830,8 +4834,8 @@ dependencies = [ [[package]] name = "kamu-auth-rebac-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "dill", @@ -4841,8 +4845,8 @@ dependencies = [ [[package]] name = "kamu-auth-rebac-services" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "dill", @@ -4857,8 +4861,8 @@ dependencies = [ [[package]] name = "kamu-auth-rebac-sqlite" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "database-common", @@ -4871,8 +4875,8 @@ dependencies = [ [[package]] name = "kamu-core" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -4902,8 +4906,8 @@ dependencies = [ [[package]] name = "kamu-data-utils" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "arrow", "arrow-digest", @@ -4924,8 +4928,8 @@ dependencies = [ [[package]] name = "kamu-datasets" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "aes-gcm", "async-trait", @@ -4944,8 +4948,8 @@ dependencies = [ [[package]] name = "kamu-datasets-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4963,8 +4967,8 @@ dependencies = [ [[package]] name = "kamu-datasets-postgres" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -4982,8 +4986,8 @@ dependencies = [ [[package]] name = "kamu-datasets-services" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -5004,8 +5008,8 @@ dependencies = [ [[package]] name = "kamu-datasets-sqlite" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -5023,12 +5027,14 @@ dependencies = [ [[package]] name = "kamu-flow-system" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", "cron", + "database-common", + "dill", "enum-variants", "event-sourcing", "internal-error", @@ -5049,14 +5055,16 @@ dependencies = [ [[package]] name = "kamu-flow-system-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", "chrono", + "database-common", "dill", "futures", + "internal-error", "kamu-flow-system", "kamu-task-system", "opendatafabric", @@ -5071,8 +5079,8 @@ dependencies = [ [[package]] name = "kamu-flow-system-postgres" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5089,8 +5097,8 @@ dependencies = [ [[package]] name = "kamu-flow-system-services" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5118,8 +5126,8 @@ dependencies = [ [[package]] name = "kamu-flow-system-sqlite" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5136,8 +5144,8 @@ dependencies = [ [[package]] name = "kamu-ingest-datafusion" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -5166,8 +5174,8 @@ dependencies = [ [[package]] name = "kamu-messaging-outbox-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -5182,8 +5190,8 @@ dependencies = [ [[package]] name = "kamu-messaging-outbox-postgres" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5201,8 +5209,8 @@ dependencies = [ [[package]] name = "kamu-messaging-outbox-sqlite" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5219,7 +5227,7 @@ dependencies = [ [[package]] name = "kamu-oracle-provider" -version = "0.34.1" +version = "0.35.0" dependencies = [ "alloy", "async-trait", @@ -5251,7 +5259,7 @@ dependencies = [ [[package]] name = "kamu-repo-tools" -version = "0.34.1" +version = "0.35.0" dependencies = [ "chrono", "clap", @@ -5264,38 +5272,59 @@ dependencies = [ [[package]] name = "kamu-task-system" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", + "database-common", "enum-variants", "event-sourcing", "kamu-core", "messaging-outbox", "opendatafabric", "serde", + "sqlx", "thiserror", "tokio-stream", ] [[package]] name = "kamu-task-system-inmem" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", + "database-common", "dill", "futures", "kamu-task-system", "opendatafabric", ] +[[package]] +name = "kamu-task-system-postgres" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" +dependencies = [ + "async-stream", + "async-trait", + "chrono", + "database-common", + "dill", + "futures", + "kamu-task-system", + "opendatafabric", + "serde_json", + "sqlx", + "tokio-stream", +] + [[package]] name = "kamu-task-system-services" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-stream", "async-trait", @@ -5314,6 +5343,24 @@ dependencies = [ "tracing", ] +[[package]] +name = "kamu-task-system-sqlite" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" +dependencies = [ + "async-stream", + "async-trait", + "chrono", + "database-common", + "dill", + "futures", + "kamu-task-system", + "opendatafabric", + "serde_json", + "sqlx", + "tokio-stream", +] + [[package]] name = "keccak" version = "0.1.5" @@ -5454,7 +5501,7 @@ checksum = "c0ff37bd590ca25063e35af745c343cb7a0271906fb7b37e4813e8f79f00268d" dependencies = [ "bitflags 2.6.0", "libc", - "redox_syscall 0.5.3", + "redox_syscall", ] [[package]] @@ -5629,8 +5676,8 @@ dependencies = [ [[package]] name = "messaging-outbox" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -5747,8 +5794,8 @@ dependencies = [ [[package]] name = "multiformats" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "bs58", "digest 0.10.7", @@ -5926,7 +5973,7 @@ checksum = "af1844ef2428cc3e1cb900be36181049ef3d3193c63e43026cfe202983b27a56" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -5970,7 +6017,7 @@ dependencies = [ [[package]] name = "observability" -version = "0.34.1" +version = "0.35.0" dependencies = [ "async-trait", "axum", @@ -6006,8 +6053,8 @@ checksum = "c08d65885ee38876c4f86fa503fb49d7b507c2b62552df7c70b2fce627e06381" [[package]] name = "opendatafabric" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "arrow", "base64 0.22.1", @@ -6227,7 +6274,7 @@ checksum = "1e401f977ab385c9e4e3ab30627d6f26d00e2c73eef317493c4ec6d468726cf8" dependencies = [ "cfg-if", "libc", - "redox_syscall 0.5.3", + "redox_syscall", "smallvec", "windows-targets 0.52.6", ] @@ -6343,7 +6390,7 @@ dependencies = [ "proc-macro2", "proc-macro2-diagnostics", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -6373,9 +6420,9 @@ checksum = "e3148f5046208a5d56bcfc03053e3ca6334e51da8dfb19b6cdc8b306fae3283e" [[package]] name = "pest" -version = "2.7.11" +version = "2.7.12" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cd53dff83f26735fdc1ca837098ccf133605d794cdae66acfc2bfac3ec809d95" +checksum = "9c73c26c01b8c87956cea613c907c9d6ecffd8d18a2a5908e5de0adfaa185cea" dependencies = [ "memchr", "thiserror", @@ -6384,9 +6431,9 @@ dependencies = [ [[package]] name = "pest_derive" -version = "2.7.11" +version = "2.7.12" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "2a548d2beca6773b1c244554d36fcf8548a8a58e74156968211567250e48e49a" +checksum = "664d22978e2815783adbdd2c588b455b1bd625299ce36b2a99881ac9627e6d8d" dependencies = [ "pest", "pest_generator", @@ -6394,22 +6441,22 @@ dependencies = [ [[package]] name = "pest_generator" -version = "2.7.11" +version = "2.7.12" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3c93a82e8d145725dcbaf44e5ea887c8a869efdcc28706df2d08c69e17077183" +checksum = "a2d5487022d5d33f4c30d91c22afa240ce2a644e87fe08caad974d4eab6badbe" dependencies = [ "pest", "pest_meta", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "pest_meta" -version = "2.7.11" +version = "2.7.12" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a941429fea7e08bedec25e4f6785b6ffaacc6b755da98df5ef3e7dcf4a124c4f" +checksum = "0091754bbd0ea592c4deb3a122ce8ecbb0753b738aa82bc055fcc2eccc8d8174" dependencies = [ "once_cell", "pest", @@ -6423,7 +6470,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b4c5cc86750666a3ed20bdaf5ca2a0344f9c67674cae0515bec2da16fbaa47db" dependencies = [ "fixedbitset", - "indexmap 2.4.0", + "indexmap 2.5.0", ] [[package]] @@ -6500,7 +6547,7 @@ checksum = "2f38a4412a78282e09a2cf38d195ea5420d15ba0602cb375210efbc877243965" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -6712,7 +6759,7 @@ checksum = "af066a9c399a26e020ada66a034357a868728e72cd426f3adcd35f80d88d88c8" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", "version_check", "yansi 1.0.1", ] @@ -6771,7 +6818,7 @@ dependencies = [ "itertools 0.12.1", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -6801,9 +6848,9 @@ dependencies = [ [[package]] name = "quinn" -version = "0.11.3" +version = "0.11.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b22d8e7369034b9a7132bc2008cac12f2013c8132b45e0554e6e20e2617f2156" +checksum = "8c7c5fdde3cdae7203427dc4f0a68fe0ed09833edc525a03456b153b79828684" dependencies = [ "bytes", "pin-project-lite", @@ -6819,9 +6866,9 @@ dependencies = [ [[package]] name = "quinn-proto" -version = "0.11.6" +version = "0.11.8" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ba92fb39ec7ad06ca2582c0ca834dfeadcaf06ddfc8e635c80aa7e1c05315fdd" +checksum = "fadfaed2cd7f389d0161bb73eeb07b7b78f8691047a6f3e73caaeae55310a4a6" dependencies = [ "bytes", "rand", @@ -6836,15 +6883,15 @@ dependencies = [ [[package]] name = "quinn-udp" -version = "0.5.4" +version = "0.5.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "8bffec3605b73c6f1754535084a85229fa8a30f86014e6c81aeec4abb68b0285" +checksum = "4fe68c2e9e1a1234e218683dbdf9f9dfcb094113c5ac2b938dfcb9bab4c4140b" dependencies = [ "libc", "once_cell", "socket2", "tracing", - "windows-sys 0.52.0", + "windows-sys 0.59.0", ] [[package]] @@ -6903,21 +6950,12 @@ dependencies = [ [[package]] name = "random-names" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "rand", ] -[[package]] -name = "redox_syscall" -version = "0.4.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4722d768eff46b75989dd134e5c353f0d6296e5aaa3132e776cbdb56be7731aa" -dependencies = [ - "bitflags 1.3.2", -] - [[package]] name = "redox_syscall" version = "0.5.3" @@ -7043,7 +7081,7 @@ dependencies = [ "http-body 1.0.1", "http-body-util", "hyper 1.4.1", - "hyper-rustls 0.27.2", + "hyper-rustls 0.27.3", "hyper-util", "ipnet", "js-sys", @@ -7070,7 +7108,7 @@ dependencies = [ "wasm-bindgen-futures", "wasm-streams", "web-sys", - "webpki-roots 0.26.3", + "webpki-roots 0.26.5", "windows-registry", ] @@ -7238,9 +7276,9 @@ dependencies = [ [[package]] name = "rustix" -version = "0.38.35" +version = "0.38.36" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a85d50532239da68e9addb745ba38ff4612a242c1c7ceea689c4bc7c2f43c36f" +checksum = "3f55e80d50763938498dd5ebb18647174e0c76dc38c5505294bb224624f30f36" dependencies = [ "bitflags 2.6.0", "errno", @@ -7300,6 +7338,19 @@ dependencies = [ "security-framework", ] +[[package]] +name = "rustls-native-certs" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fcaf18a4f2be7326cd874a5fa579fae794320a0f388d365dca7e480e55f83f8a" +dependencies = [ + "openssl-probe", + "rustls-pemfile 2.1.3", + "rustls-pki-types", + "schannel", + "security-framework", +] + [[package]] name = "rustls-pemfile" version = "1.0.4" @@ -7517,14 +7568,14 @@ checksum = "a5831b979fd7b5439637af1752d535ff49f4860c0f341d1baeb6faf0f4242170" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "serde_json" -version = "1.0.127" +version = "1.0.128" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "8043c06d9f82bd7271361ed64f415fe5e12a77fdb52e573e7f06a516dea329ad" +checksum = "6ff5456707a1de34e7e37f2a6fd3d3f808c318259cbd01ab6377795054b483d8" dependencies = [ "itoa", "memchr", @@ -7573,7 +7624,7 @@ dependencies = [ "chrono", "hex", "indexmap 1.9.3", - "indexmap 2.4.0", + "indexmap 2.5.0", "serde", "serde_derive", "serde_json", @@ -7590,7 +7641,7 @@ dependencies = [ "darling", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -7599,7 +7650,7 @@ version = "0.9.34+deprecated" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6a8b1a1a2ebf674015cc02edccce75287f1a0130d394307b36743c2f5d504b47" dependencies = [ - "indexmap 2.4.0", + "indexmap 2.5.0", "itoa", "ryu", "serde", @@ -7808,9 +7859,9 @@ dependencies = [ [[package]] name = "sqlformat" -version = "0.2.4" +version = "0.2.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f895e3734318cc55f1fe66258926c9b910c124d47520339efecbb6c59cec7c1f" +checksum = "7bba3a93db0cc4f7bdece8bb09e77e2e785c20bfebf79eb8340ed80708048790" dependencies = [ "nom", "unicode_categories", @@ -7834,14 +7885,14 @@ checksum = "01b2e185515564f15375f593fb966b5718bc624ba77fe49fa4616ad619690554" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "sqlx" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fcfa89bea9500db4a0d038513d7a060566bfc51d46d1c014847049a45cce85e8" +checksum = "93334716a037193fac19df402f8571269c84a00852f6a7066b5d2616dcd64d3e" dependencies = [ "sqlx-core", "sqlx-macros", @@ -7852,9 +7903,9 @@ dependencies = [ [[package]] name = "sqlx-core" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d06e2f2bd861719b1f3f0c7dbe1d80c30bf59e76cf019f07d9014ed7eefb8e08" +checksum = "d4d8060b456358185f7d50c55d9b5066ad956956fddec42ee2e8567134a8936e" dependencies = [ "atoi", "byteorder", @@ -7872,7 +7923,7 @@ dependencies = [ "hashbrown 0.14.5", "hashlink", "hex", - "indexmap 2.4.0", + "indexmap 2.5.0", "log", "memchr", "once_cell", @@ -7891,27 +7942,27 @@ dependencies = [ "tracing", "url", "uuid", - "webpki-roots 0.26.3", + "webpki-roots 0.26.5", ] [[package]] name = "sqlx-macros" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "2f998a9defdbd48ed005a89362bd40dd2117502f15294f61c8d47034107dbbdc" +checksum = "cac0692bcc9de3b073e8d747391827297e075c7710ff6276d9f7a1f3d58c6657" dependencies = [ "proc-macro2", "quote", "sqlx-core", "sqlx-macros-core", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] name = "sqlx-macros-core" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3d100558134176a2629d46cec0c8891ba0be8910f7896abfdb75ef4ab6f4e7ce" +checksum = "1804e8a7c7865599c9c79be146dc8a9fd8cc86935fa641d3ea58e5f0688abaa5" dependencies = [ "dotenvy", "either", @@ -7927,7 +7978,7 @@ dependencies = [ "sqlx-mysql", "sqlx-postgres", "sqlx-sqlite", - "syn 2.0.76", + "syn 2.0.77", "tempfile", "tokio", "url", @@ -7935,9 +7986,9 @@ dependencies = [ [[package]] name = "sqlx-mysql" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "936cac0ab331b14cb3921c62156d913e4c15b74fb6ec0f3146bd4ef6e4fb3c12" +checksum = "64bb4714269afa44aef2755150a0fc19d756fb580a67db8885608cf02f47d06a" dependencies = [ "atoi", "base64 0.22.1", @@ -7979,9 +8030,9 @@ dependencies = [ [[package]] name = "sqlx-postgres" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9734dbce698c67ecf67c442f768a5e90a49b2a4d61a9f1d59f73874bd4cf0710" +checksum = "6fa91a732d854c5d7726349bb4bb879bb9478993ceb764247660aee25f67c2f8" dependencies = [ "atoi", "base64 0.22.1", @@ -8019,9 +8070,9 @@ dependencies = [ [[package]] name = "sqlx-sqlite" -version = "0.8.1" +version = "0.8.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a75b419c3c1b1697833dd927bdc4c6545a620bc1bbafabd44e1efbe9afcd337e" +checksum = "d5b2cf34a45953bfd3daaf3db0f7a7878ab9b7a6b91b422d24a7a9e4c857b680" dependencies = [ "atoi", "chrono", @@ -8119,7 +8170,7 @@ dependencies = [ "proc-macro2", "quote", "rustversion", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8132,7 +8183,7 @@ dependencies = [ "proc-macro2", "quote", "rustversion", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8154,9 +8205,9 @@ dependencies = [ [[package]] name = "syn" -version = "2.0.76" +version = "2.0.77" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "578e081a14e0cefc3279b0472138c513f37b41a08d5a3cca9b6e4e8ceb6cd525" +checksum = "9f35bcdf61fd8e7be6caf75f429fdca8beb3ed76584befb503b1569faee373ed" dependencies = [ "proc-macro2", "quote", @@ -8172,7 +8223,7 @@ dependencies = [ "paste", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8278,7 +8329,7 @@ dependencies = [ "proc-macro2", "quote", "sha2", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8300,7 +8351,7 @@ checksum = "5999e24eaa32083191ba4e425deb75cdf25efefabe5aaccb7446dd0d4122a3f5" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8320,7 +8371,7 @@ checksum = "a4558b58466b9ad7ca0f102865eccc95938dca1a74a856f2b57b6629050da261" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8386,8 +8437,8 @@ dependencies = [ [[package]] name = "time-source" -version = "0.198.2" -source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.198.2#c2bbe8c52e4ac4513afda36ed063f7dc08ac5803" +version = "0.199.0" +source = "git+https://github.com/kamu-data/kamu-cli?tag=v0.199.0#43de6c2226b844e932c8575d5f4b7fabdf3f7d6e" dependencies = [ "async-trait", "chrono", @@ -8455,7 +8506,7 @@ checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -8481,9 +8532,9 @@ dependencies = [ [[package]] name = "tokio-stream" -version = "0.1.15" +version = "0.1.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "267ac89e0bec6e691e5813911606935d77c476ff49024f98abcea3e7b15e37af" +checksum = "4f4e6ce100d0eb49a2734f8c0812bcd324cf357d21810932c5df6b96ef2b86f1" dependencies = [ "futures-core", "pin-project-lite", @@ -8519,14 +8570,14 @@ dependencies = [ "tokio", "tokio-rustls 0.26.0", "tungstenite 0.23.0", - "webpki-roots 0.26.3", + "webpki-roots 0.26.5", ] [[package]] name = "tokio-util" -version = "0.7.11" +version = "0.7.12" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9cf6b47b3771c49ac75ad09a6162f53ad4b8088b76ac60e8ec1455b31a189fe1" +checksum = "61e7c3654c13bcd040d4a03abee2c75b1d14a37b423cf5a813ceae1cc903ec6a" dependencies = [ "bytes", "futures-core", @@ -8565,7 +8616,7 @@ version = "0.19.15" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1b5bb770da30e5cbfde35a2d7b9b8a2c4b8ef89548a7a6aeab5c9a576e3e7421" dependencies = [ - "indexmap 2.4.0", + "indexmap 2.5.0", "toml_datetime", "winnow 0.5.40", ] @@ -8576,7 +8627,7 @@ version = "0.22.20" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "583c44c02ad26b0c3f3066fe629275e50627026c51ac2e595cca4c230ce1ce1d" dependencies = [ - "indexmap 2.4.0", + "indexmap 2.5.0", "serde", "serde_spanned", "toml_datetime", @@ -8699,7 +8750,7 @@ checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -9124,7 +9175,7 @@ dependencies = [ "once_cell", "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", "wasm-bindgen-shared", ] @@ -9158,7 +9209,7 @@ checksum = "afc340c74d9005395cf9dd098506f7f44e38f2b4a21c6aaacf9a105ea5e1e836" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", "wasm-bindgen-backend", "wasm-bindgen-shared", ] @@ -9210,20 +9261,20 @@ checksum = "5f20c57d8d7db6d3b86154206ae5d8fba62dd39573114de97c2cb0578251f8e1" [[package]] name = "webpki-roots" -version = "0.26.3" +version = "0.26.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bd7c23921eeb1713a4e851530e9b9756e4fb0e89978582942612524cf09f01cd" +checksum = "0bd24728e5af82c6c4ec1b66ac4844bdf8156257fccda846ec58b42cd0cdbe6a" dependencies = [ "rustls-pki-types", ] [[package]] name = "whoami" -version = "1.5.1" +version = "1.5.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a44ab49fad634e88f55bf8f9bb3abd2f27d7204172a112c7c9987e01c1c94ea9" +checksum = "372d5b87f58ec45c384ba03563b03544dc5fadc3983e434b286913f5b4a9bb6d" dependencies = [ - "redox_syscall 0.4.1", + "redox_syscall", "wasite", ] @@ -9563,7 +9614,7 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] @@ -9583,7 +9634,7 @@ checksum = "ce36e65b0d2999d2aafac989fb249189a141aee1f53c612c1f37d72631959f69" dependencies = [ "proc-macro2", "quote", - "syn 2.0.76", + "syn 2.0.77", ] [[package]] diff --git a/Cargo.toml b/Cargo.toml index 6423a63e..ff3d96c2 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -13,54 +13,57 @@ resolver = "2" [workspace.dependencies] # Utils -graceful-shutdown = { path = "src/utils/graceful-shutdown", version = "0.34.1", default-features = false } -observability = { path = "src/utils/observability", version = "0.34.1", default-features = false } +graceful-shutdown = { path = "src/utils/graceful-shutdown", version = "0.35.0", default-features = false } +observability = { path = "src/utils/observability", version = "0.35.0", default-features = false } # Utils (core) -container-runtime = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -database-common = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -database-common-macros = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -http-common = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -internal-error = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -messaging-outbox = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -random-names = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -time-source = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } +container-runtime = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +database-common = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +database-common-macros = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +http-common = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +internal-error = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +messaging-outbox = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +random-names = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +time-source = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } # Domain -opendatafabric = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-task-system = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-task-system-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-accounts = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-datasets = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } +opendatafabric = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-task-system = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-task-system-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-flow-system = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-flow-system-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-accounts = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-datasets = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } # Infra -kamu = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-task-system-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-flow-system-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-flow-system-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-flow-system-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-flow-system-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-graphql = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-http = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-oauth = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-odata = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-auth-oso = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-adapter-flight-sql = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-accounts-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-accounts-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-accounts-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-accounts-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-datasets-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-datasets-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-datasets-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-datasets-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-messaging-outbox-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-messaging-outbox-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-messaging-outbox-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-auth-rebac-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-auth-rebac-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } -kamu-auth-rebac-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.198.2", version = "0.198.2", default-features = false } +kamu = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-task-system-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-task-system-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-task-system-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-flow-system-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-flow-system-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-flow-system-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-graphql = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-http = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-oauth = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-odata = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-auth-oso = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-adapter-flight-sql = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-accounts-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-accounts-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-accounts-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-accounts-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-datasets-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-datasets-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-datasets-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-datasets-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-messaging-outbox-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-messaging-outbox-postgres = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-messaging-outbox-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-auth-rebac-inmem = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-auth-rebac-services = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } +kamu-auth-rebac-sqlite = { git = "https://github.com/kamu-data/kamu-cli", tag = "v0.199.0", version = "0.199.0", default-features = false } [workspace.package] -version = "0.34.1" +version = "0.35.0" edition = "2021" homepage = "https://github.com/kamu-data/kamu-platform" repository = "https://github.com/kamu-data/kamu-platform" diff --git a/LICENSE.txt b/LICENSE.txt index 360b998d..fb64531c 100644 --- a/LICENSE.txt +++ b/LICENSE.txt @@ -11,7 +11,7 @@ Business Source License 1.1 Licensor: Kamu Data, Inc. -Licensed Work: Kamu Platform Version 0.34.1 +Licensed Work: Kamu Platform Version 0.35.0 The Licensed Work is © 2023 Kamu Data, Inc. Additional Use Grant: You may use the Licensed Work for any purpose, @@ -24,7 +24,7 @@ Additional Use Grant: You may use the Licensed Work for any purpose, Licensed Work where data or transformations are controlled by such third parties. -Change Date: 2028-08-30 +Change Date: 2028-09-06 Change License: Apache License, Version 2.0 diff --git a/deny.toml b/deny.toml index 0418ee0f..f63354b1 100644 --- a/deny.toml +++ b/deny.toml @@ -81,4 +81,8 @@ allow-org = { github = ["kamu-data", "apache"] } yanked = "deny" # TODO: Remove when patches are available # See more: https://rustsec.org/advisories/RUSTSEC-2023-0071.html -ignore = ["RUSTSEC-2023-0071"] +ignore = [ + "RUSTSEC-2023-0071", # https://rustsec.org/advisories/RUSTSEC-2023-0071.html, + "RUSTSEC-2024-0370", # https://rustsec.org/advisories/RUSTSEC-2024-0370.html +] + diff --git a/src/app/api-server/Cargo.toml b/src/app/api-server/Cargo.toml index 0cae1513..d1ac5b30 100644 --- a/src/app/api-server/Cargo.toml +++ b/src/app/api-server/Cargo.toml @@ -26,8 +26,12 @@ time-source = { workspace = true } database-common = { workspace = true } database-common-macros = { workspace = true } kamu = { workspace = true } +kamu-task-system = { workspace = true } kamu-task-system-services = { workspace = true } kamu-task-system-inmem = { workspace = true } +kamu-task-system-postgres = { workspace = true } +kamu-task-system-sqlite = { workspace = true } +kamu-flow-system = { workspace = true } kamu-flow-system-services = { workspace = true } kamu-flow-system-inmem = { workspace = true } kamu-flow-system-postgres = { workspace = true } diff --git a/src/app/api-server/src/app.rs b/src/app/api-server/src/app.rs index 8f002a20..92988ef6 100644 --- a/src/app/api-server/src/app.rs +++ b/src/app/api-server/src/app.rs @@ -161,11 +161,11 @@ pub async fn run(matches: clap::ArgMatches, config: ApiServerConfig) -> Result<( .build(); let task_executor = system_catalog - .get_one::() + .get_one::() .unwrap(); - let flow_service = system_catalog - .get_one::() + let flow_executor = system_catalog + .get_one::() .unwrap(); let outbox_processor = system_catalog @@ -183,17 +183,23 @@ pub async fn run(matches: clap::ArgMatches, config: ApiServerConfig) -> Result<( "Serving traffic" ); + // Pre-run phase + task_executor.pre_run().await?; + flow_executor.pre_run(now).await?; + outbox_processor.pre_run().await?; + // TODO: Support graceful shutdown for other protocols let http_server = http_server.with_graceful_shutdown(async { shutdown_requested.await; }); + // Run phase // TODO: PERF: Do we need to spawn these into separate tasks? tokio::select! { res = http_server => { res.int_err() }, res = flightsql_server.run() => { res.int_err() }, res = task_executor.run() => { res.int_err() }, - res = flow_service.run(now) => { res.int_err() }, + res = flow_executor.run() => { res.int_err() }, res = outbox_processor.run() => { res.int_err() }, } } @@ -360,14 +366,12 @@ pub async fn init_dependencies( &mut b, kamu::domain::MESSAGE_PRODUCER_KAMU_CORE_DATASET_SERVICE, ); - messaging_outbox::register_message_dispatcher::< - kamu_task_system_inmem::domain::TaskProgressMessage, - >( + messaging_outbox::register_message_dispatcher::( &mut b, - kamu_task_system_inmem::domain::MESSAGE_PRODUCER_KAMU_TASK_EXECUTOR, + kamu_task_system::MESSAGE_PRODUCER_KAMU_TASK_EXECUTOR, ); messaging_outbox::register_message_dispatcher::< - kamu_flow_system_inmem::domain::FlowConfigurationUpdatedMessage, + kamu_flow_system::FlowConfigurationUpdatedMessage, >( &mut b, kamu_flow_system_services::MESSAGE_PRODUCER_KAMU_FLOW_CONFIGURATION_SERVICE, @@ -378,15 +382,13 @@ pub async fn init_dependencies( config.outbox.batch_size.unwrap(), )); - b.add::(); - b.add::(); + kamu_task_system_services::register_dependencies(&mut b); - b.add::(); - b.add::(); - b.add_value(kamu_flow_system_inmem::domain::FlowServiceRunConfig::new( + b.add_value(kamu_flow_system::FlowExecutorConfig::new( chrono::Duration::try_seconds(1).unwrap(), chrono::Duration::try_minutes(1).unwrap(), )); + kamu_flow_system_services::register_dependencies(&mut b); b.add::(); b.add::(); diff --git a/src/app/api-server/src/database.rs b/src/app/api-server/src/database.rs index d8eab3fc..3d0e6df8 100644 --- a/src/app/api-server/src/database.rs +++ b/src/app/api-server/src/database.rs @@ -42,13 +42,6 @@ pub(crate) fn configure_database_components( raw_db_config: &DatabaseConfig, db_connection_settings: DatabaseConnectionSettings, ) { - // TODO: Remove after adding implementation of FlowEventStore for databases - b.add::(); - - // TODO: Delete after preparing services for transactional work and replace with - // permanent storage options - b.add::(); - match db_connection_settings.provider { DatabaseProvider::Postgres => { PostgresPlugin::init_database_components(b); @@ -58,6 +51,9 @@ pub(crate) fn configure_database_components( b.add::(); b.add::(); + b.add::(); + + b.add::(); b.add::(); b.add::(); @@ -72,7 +68,10 @@ pub(crate) fn configure_database_components( b.add::(); b.add::(); - b.add::(); + b.add::(); + b.add::(); + + b.add::(); b.add::(); b.add::(); @@ -102,7 +101,7 @@ pub(crate) fn configure_in_memory_components(b: &mut CatalogBuilder) { b.add::(); b.add::(); b.add::(); - b.add::(); + b.add::(); b.add::(); NoOpDatabasePlugin::init_database_components(b);