From 5e59a26c0fe142f3e695c202a146c45a33f62414 Mon Sep 17 00:00:00 2001 From: Reinier Maas Date: Fri, 6 Feb 2026 12:00:17 +0100 Subject: [PATCH 1/3] Typos: Allow the `missable` spelling --- typos.toml | 4 ++++ 1 file changed, 4 insertions(+) create mode 100644 typos.toml diff --git a/typos.toml b/typos.toml new file mode 100644 index 0000000..40af6f6 --- /dev/null +++ b/typos.toml @@ -0,0 +1,4 @@ +[default] + +[default.extend-words] +missable = "missable" From bcdda15225c682fa02341e26563b3087c0369d14 Mon Sep 17 00:00:00 2001 From: Reinier Maas Date: Fri, 6 Feb 2026 12:00:40 +0100 Subject: [PATCH 2/3] Nix: Remove duplicate commented package and sort --- extra/experimentation/shell.nix | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/extra/experimentation/shell.nix b/extra/experimentation/shell.nix index 7c5573a..699c102 100644 --- a/extra/experimentation/shell.nix +++ b/extra/experimentation/shell.nix @@ -1,16 +1,15 @@ { pkgs ? import ./nixpkgs-pinned.nix {} }: pkgs.mkShell rec { python = pkgs.python311.withPackages (ps: [ - # ps.google-cloud-storage - ps.sqlite-utils ps.fastapi - ps.uvicorn + ps.google-cloud-storage ps.httpx + ps.ipython ps.pytest ps.requests - ps.google-cloud-storage - ps.ipython + ps.sqlite-utils ps.types-requests + ps.uvicorn ]); buildInputs = with pkgs; [ sqlite From 4a1c4dca12987376b4dd09d5823741daba01361d Mon Sep 17 00:00:00 2001 From: Reinier Maas Date: Fri, 6 Feb 2026 12:01:20 +0100 Subject: [PATCH 3/3] Typos: Use `submission` and `TODO` --- libs/opsqueue_python/src/producer.rs | 2 +- opsqueue/src/consumer/client.rs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/libs/opsqueue_python/src/producer.rs b/libs/opsqueue_python/src/producer.rs index 7e16ba5..37a1419 100644 --- a/libs/opsqueue_python/src/producer.rs +++ b/libs/opsqueue_python/src/producer.rs @@ -143,7 +143,7 @@ impl ProducerClient { } /// Attempts to find the submission ID if only the prefix of the submission - /// (AKA the path at which the submision's chunks are stored in the object store) + /// (AKA the path at which the submission's chunks are stored in the object store) /// is known. pub fn lookup_submission_id_by_prefix( &self, diff --git a/opsqueue/src/consumer/client.rs b/opsqueue/src/consumer/client.rs index 27c554f..1105cb0 100644 --- a/opsqueue/src/consumer/client.rs +++ b/opsqueue/src/consumer/client.rs @@ -147,7 +147,7 @@ impl OuterClient { } } -// TOOD: Set max retries to `None`; +// TODO: Set max retries to `None`; // will require either writing our own Backoff (iterator) // or extending the backon crate. fn retry_policy() -> impl BackoffBuilder { @@ -279,7 +279,7 @@ impl Client { } else if msg.is_pong() { tracing::debug!("Received Pong reply to heartbeat, nice!"); } else if msg.is_binary() { - let msg: ServerToClientMessage = msg.try_into().expect("Unparseable ServerToClientMessage"); + let msg: ServerToClientMessage = msg.try_into().expect("Unparsable ServerToClientMessage"); match msg { ServerToClientMessage::Sync(envelope) => { let mut in_flight_requests = in_flight_requests.lock().await;