Bump version to 0.35.0

Author: jerbaroo

Cargo.lock

@@ -9,7 +9,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.34.0"
+version = "0.35.0"
 
 
 [workspace.lints.clippy]

Cargo.toml

@@ -49,7 +49,7 @@ class SubmissionNotCancellableError(Exception):
     def __init__(
         self,
         submission: opsqueue_internal.SubmissionNotCancellable,
-        chunk: Optional[opsqueue_internal.ChunkFailed]=None,
+        chunk: Optional[opsqueue_internal.ChunkFailed] = None,
     ):
         super().__init__()
         self.submission = submission

libs/opsqueue_python/python/opsqueue/exceptions.py

@@ -500,9 +500,10 @@ impl From<opsqueue::common::errors::SubmissionNotCancellable> for SubmissionNotC
             Failed(s, c) => {
                 let chunk = ChunkFailed::from_internal(c, &s);
                 SubmissionNotCancellable::Failed {
-                    submission: s.into(), chunk
+                    submission: s.into(),
+                    chunk,
                 }
-            },
+            }
             Cancelled(s) => SubmissionNotCancellable::Cancelled {
                 submission: s.into(),
             },

libs/opsqueue_python/src/common.rs

@@ -4,7 +4,7 @@ use std::error::Error;
 
 use opsqueue::common::chunk::ChunkId;
 use opsqueue::common::errors::{
-    ChunkNotFound, IncorrectUsage, SubmissionNotFound, SubmissionNotCancellable,
+    ChunkNotFound, IncorrectUsage, SubmissionNotCancellable, SubmissionNotFound,
     UnexpectedOpsqueueConsumerServerResponse, E,
 };
 use pyo3::exceptions::PyBaseException;

libs/opsqueue_python/src/errors.rs

@@ -360,6 +360,7 @@ def assert_submission_failed_has_metadata(x: SubmissionFailed) -> None:
         assert submission is not None
         assert_submission_failed_has_metadata(submission.submission)
 
+
 def test_cancel_submission_not_found(
     opsqueue: OpsqueueProcess, any_consumer_strategy: StrategyDescription
 ) -> None:
@@ -374,6 +375,7 @@ def test_cancel_submission_not_found(
         producer_client.cancel_submission(SubmissionId(0))
     assert exc_info.value.submission_id == submission_id
 
+
 def test_cancel_in_progress_and_already_cancelled_submissions(
     opsqueue: OpsqueueProcess, any_consumer_strategy: StrategyDescription
 ) -> None:
@@ -383,7 +385,9 @@ def test_cancel_in_progress_and_already_cancelled_submissions(
 
     """
 
-    url = "file:///tmp/opsqueue/test_cancel_in_progress_and_already_cancelled_submissions"
+    url = (
+        "file:///tmp/opsqueue/test_cancel_in_progress_and_already_cancelled_submissions"
+    )
     producer_client = ProducerClient(f"localhost:{opsqueue.port}", url)
     submission_id = producer_client.insert_submission((1, 2, 3), chunk_size=1)
     status = producer_client.get_submission_status(submission_id)
@@ -400,6 +404,7 @@ def test_cancel_in_progress_and_already_cancelled_submissions(
         producer_client.cancel_submission(submission_id)
     assert isinstance(exc_info.value.submission, SubmissionNotCancellable.Cancelled)
 
+
 def test_cancel_complete_submission(
     opsqueue: OpsqueueProcess, any_consumer_strategy: StrategyDescription
 ) -> None:
@@ -428,6 +433,7 @@ def run_consumer() -> None:
         assert isinstance(exc_info.value.submission, SubmissionNotCancellable.Completed)
         assert exc_info.value.chunk is None
 
+
 def test_cancel_failed_submission(
     opsqueue: OpsqueueProcess, any_consumer_strategy: StrategyDescription
 ) -> None: