chore: bump fluvio to 0.12.1 and rev crate version (#502)

Author: digikata

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"

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,