From 59b7c1566b28dfd142a796be85569b262867528f Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Tue, 13 Aug 2024 14:56:31 +0000 Subject: [PATCH 1/2] Bump log from 0.4.21 to 0.4.22 Bumps [log](https://github.com/rust-lang/log) from 0.4.21 to 0.4.22. - [Release notes](https://github.com/rust-lang/log/releases) - [Changelog](https://github.com/rust-lang/log/blob/master/CHANGELOG.md) - [Commits](https://github.com/rust-lang/log/compare/0.4.21...0.4.22) --- updated-dependencies: - dependency-name: log dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] --- Cargo.lock | 4 ++-- tremor-connectors-azure/Cargo.toml | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 50850b1c5d..5510d069b1 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3810,9 +3810,9 @@ dependencies = [ [[package]] name = "log" -version = "0.4.21" +version = "0.4.22" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "90ed8c1e510134f979dbc4f070f87d4313098b704861a105fe34231c70a3901c" +checksum = "a7a70ba024b9dc04c27ea2f0c0548feb474ec5c54bba33a7f72f873a39d07b24" dependencies = [ "serde", "value-bag", diff --git a/tremor-connectors-azure/Cargo.toml b/tremor-connectors-azure/Cargo.toml index 0ccf8c410f..9fa976b452 100644 --- a/tremor-connectors-azure/Cargo.toml +++ b/tremor-connectors-azure/Cargo.toml @@ -28,7 +28,7 @@ async-trait = "0.1.81" url = "2.5.2" reqwest = { version = "0.12.4", default-features = false, features = ["json"] } tokio = "1.39.2" -log = "0.4.21" +log = "0.4.22" tremor-script = { version = "0.13.0-rc.29", path = "../tremor-script" } bytes = "1.6.1" futures = { version = "0.3.30", default-features = false, features = [ From e829c5576d94d7893b802df7c990474133e53762 Mon Sep 17 00:00:00 2001 From: "Heinz N. Gies" Date: Tue, 13 Aug 2024 17:07:35 +0200 Subject: [PATCH 2/2] Obey clippy Signed-off-by: Heinz N. Gies --- tremor-connectors/src/impls/kafka.rs | 5 +---- tremor-connectors/src/lib.rs | 2 +- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/tremor-connectors/src/impls/kafka.rs b/tremor-connectors/src/impls/kafka.rs index 088cbc0c89..963d5e4e60 100644 --- a/tremor-connectors/src/impls/kafka.rs +++ b/tremor-connectors/src/impls/kafka.rs @@ -497,10 +497,7 @@ where rdkafka::config::RDKafkaLogLevel::Warning => { warn!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message); } - rdkafka::config::RDKafkaLogLevel::Notice => { - info!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message); - } - rdkafka::config::RDKafkaLogLevel::Info => { + rdkafka::config::RDKafkaLogLevel::Notice | rdkafka::config::RDKafkaLogLevel::Info => { info!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message); } rdkafka::config::RDKafkaLogLevel::Debug => { diff --git a/tremor-connectors/src/lib.rs b/tremor-connectors/src/lib.rs index e13d5d5e8d..dffcf4addd 100644 --- a/tremor-connectors/src/lib.rs +++ b/tremor-connectors/src/lib.rs @@ -692,7 +692,7 @@ async fn connector_task( info!("{ctx} Ignoring SourceDrained Msg. Current state: {connector_state}",); } Msg::SinkDrained => { - info!("{ctx} Ignoring SourceDrained Msg. Current state: {connector_state}",); + info!("{ctx} Ignoring SinkDrained Msg. Current state: {connector_state}",); } Msg::Stop(sender) => { info!("{ctx} Stopping...");