Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 4 additions & 5 deletions extra/experimentation/shell.nix
Original file line number Diff line number Diff line change
@@ -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
Expand Down
2 changes: 1 addition & 1 deletion libs/opsqueue_python/src/producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
4 changes: 2 additions & 2 deletions opsqueue/src/consumer/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down Expand Up @@ -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;
Expand Down
4 changes: 4 additions & 0 deletions typos.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
[default]

[default.extend-words]
missable = "missable"
Loading