diff --git a/packages/core/services/cluster/src/workflows/server/install/install_scripts/components/vector.rs b/packages/core/services/cluster/src/workflows/server/install/install_scripts/components/vector.rs index acfda43a8b..100b645d36 100644 --- a/packages/core/services/cluster/src/workflows/server/install/install_scripts/components/vector.rs +++ b/packages/core/services/cluster/src/workflows/server/install/install_scripts/components/vector.rs @@ -74,7 +74,7 @@ pub fn configure(namespace: &str, config: &Config, pool_type: PoolType) -> Globa // Buffer to disk for durability & reduce memory usage "buffer": { "type": "disk", - "max_size": 2 * 1024 * 1024 * 1024, // 2 GiB + "max_size": 2u64 * 1024 * 1024 * 1024, // 2 GiB "when_full": "block" } } diff --git a/packages/edge/infra/client/manager/src/image_download_handler.rs b/packages/edge/infra/client/manager/src/image_download_handler.rs index 9ea90150c9..d12d0c5648 100644 --- a/packages/edge/infra/client/manager/src/image_download_handler.rs +++ b/packages/edge/infra/client/manager/src/image_download_handler.rs @@ -43,11 +43,7 @@ impl ImageDownloadHandler { // The image download started at some point in the current runtime Entry::Occupied(entry) => entry.get().clone(), // The image is not currently being downloaded - Entry::Vacant(entry) => { - let entry = entry.insert_entry(Arc::new(Mutex::new(false))); - - entry.get().clone() - } + Entry::Vacant(entry) => entry.insert(Arc::new(Mutex::new(false))).clone(), }; drop(downloads_guard); diff --git a/packages/edge/services/pegboard/src/workflows/actor/setup.rs b/packages/edge/services/pegboard/src/workflows/actor/setup.rs index d37580ed84..2a8bd5892f 100644 --- a/packages/edge/services/pegboard/src/workflows/actor/setup.rs +++ b/packages/edge/services/pegboard/src/workflows/actor/setup.rs @@ -705,10 +705,11 @@ struct ResolveArtifactsInput { dc_build_delivery_method: BuildDeliveryMethod, } -#[derive(Debug, Serialize, Deserialize, Hash)] +#[derive(Debug, Serialize, Deserialize)] struct ResolveArtifactsOutput { artifact_url_stub: String, fallback_artifact_url: Option, + #[serde(default)] artifact_size_bytes: u64, }