diff --git a/Cargo.lock b/Cargo.lock index 26c655e..948f7b4 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -2085,7 +2085,7 @@ dependencies = [ [[package]] name = "opsqueue" -version = "0.35.1" +version = "0.35.2" dependencies = [ "anyhow", "arc-swap", @@ -2139,7 +2139,7 @@ dependencies = [ [[package]] name = "opsqueue_python" -version = "0.35.1" +version = "0.35.2" dependencies = [ "anyhow", "chrono", diff --git a/justfile b/justfile index ee1baa4..cdba370 100644 --- a/justfile +++ b/justfile @@ -80,6 +80,7 @@ lint-heavy: clippy mypy [group('lint')] clippy: cargo clippy --no-deps --fix --allow-dirty --allow-staged -- -Dwarnings + cargo clippy --no-deps -- -Dwarnings # Python static analysis type-checker [group('lint')] diff --git a/libs/opsqueue_python/src/producer.rs b/libs/opsqueue_python/src/producer.rs index 7d4266c..5598172 100644 --- a/libs/opsqueue_python/src/producer.rs +++ b/libs/opsqueue_python/src/producer.rs @@ -123,6 +123,7 @@ impl ProducerClient { /// /// Will return an error if the submission is already complete, failed, or /// cancelled, or if the submission could not be found. + #[allow(clippy::result_large_err, clippy::type_complexity)] pub fn cancel_submission( &self, py: Python<'_>, @@ -284,7 +285,7 @@ impl ProducerClient { }) } - #[allow(clippy::type_complexity)] + #[allow(clippy::result_large_err, clippy::type_complexity)] pub fn try_stream_completed_submission_chunks( &self, py: Python<'_>, @@ -313,7 +314,7 @@ impl ProducerClient { } #[pyo3(signature = (chunk_contents, metadata=None, strategic_metadata=None, chunk_size=None, otel_trace_carrier=CarrierMap::default()))] - #[allow(clippy::type_complexity)] + #[allow(clippy::result_large_err, clippy::type_complexity)] pub fn run_submission_chunks( &self, py: Python<'_>, @@ -364,7 +365,7 @@ impl ProducerClient { /// to reduce the latency of tiny submissions. /// This interval is then doubled for each subsequent poll, /// until we check every few seconds. - #[allow(clippy::type_complexity)] + #[allow(clippy::result_large_err, clippy::type_complexity)] pub fn blocking_stream_completed_submission_chunks( &self, py: Python<'_>,