From 9a27066dbba4dde90aa1efc6eaca9f568e87bdfd Mon Sep 17 00:00:00 2001
From: Alan Chen <alan@infinyon.com>
Date: Thu, 31 Oct 2024 17:12:37 -0700
Subject: [PATCH] chore: bump fluvio to 0.12.1 and rev crate version (#502)

---
 Cargo.toml            | 10 +++++-----
 src/produce_output.rs |  4 ++--
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index fc113f8..674389d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "_fluvio_python"
-version = "0.16.4"
+version = "0.16.5"
 edition = "2021"
 authors = ["Fluvio Contributors <team@fluvio.io>"]
 
@@ -38,10 +38,10 @@ url = "2.5.0"
 webbrowser = "1.0.0"
 
 fluvio-future = { version = "0.7.0", features = ["task", "io", "native_tls", "subscriber"] }
-fluvio = { features = ["admin", "rustls"], git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.0" }
-fluvio-types = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.0" }
-fluvio-sc-schema = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.0" }
-fluvio-controlplane-metadata = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.0" }
+fluvio = { features = ["admin", "rustls"], git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.1" }
+fluvio-types = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.1" }
+fluvio-sc-schema = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.1" }
+fluvio-controlplane-metadata = { git = "https://github.com/infinyon/fluvio.git", tag = "v0.12.1" }
 
 # transitive version selection
 parking_lot = "0.12.3"
diff --git a/src/produce_output.rs b/src/produce_output.rs
index 6cdda0f..8a84d41 100644
--- a/src/produce_output.rs
+++ b/src/produce_output.rs
@@ -31,7 +31,7 @@ impl ProduceOutput {
             .map(|produce_output| {
                 run_block_on(produce_output.wait())
                     .map(|metadata| RecordMetadata { inner: metadata })
-                    .map_err(|err| FluvioError::FluvioErr(err))
+                    .map_err(FluvioError::FluvioErr)
             })
             .transpose()
     }
@@ -45,7 +45,7 @@ impl ProduceOutput {
                         .wait()
                         .await
                         .map(|metadata| RecordMetadata { inner: metadata })
-                        .map_err(|err| FluvioError::FluvioErr(err))?;
+                        .map_err(FluvioError::FluvioErr)?;
                     Some(pout)
                 }
                 None => None,