Merge pull request #34389 from MaterializeInc/dependabot/cargo/simple2-c857efdc00

build(deps): bump the simple2 group with 4 updates

Author: def-

Cargo.lock

@@ -17,7 +17,7 @@ mz-storage-types = { path = "../storage-types" }
 serde = "1.0.219"
 timely = "0.25.1"
 workspace-hack = { version = "0.0.0", path = "../workspace-hack", optional = true }
-tracing = "0.1.37"
+tracing = "0.1.43"
 
 [package.metadata.cargo-udeps.ignore]
 normal = ["workspace-hack"]

src/adapter-types/Cargo.toml

@@ -91,10 +91,10 @@ timely = "0.25.1"
 tokio = { version = "1.48.0", features = ["rt", "time"] }
 tokio-postgres = { version = "0.7.15" }
 tokio-stream = "0.1.17"
-tracing = "0.1.37"
+tracing = "0.1.43"
 tracing-core = "0.1.35"
 tracing-opentelemetry = { version = "0.25.0" }
-tracing-subscriber = "0.3.19"
+tracing-subscriber = "0.3.22"
 thiserror = "2.0.17"
 url = "2.5.7"
 uuid = { version = "1.18.1" }

src/adapter/Cargo.toml

@@ -994,7 +994,7 @@ impl CatalogState {
         let (stmt, resolved_ids) = mz_sql::names::resolve(catalog, stmt)?;
         let plan = mz_sql::plan::plan(pcx, catalog, stmt, &Params::empty(), &resolved_ids)?;
 
-        return Ok((plan, resolved_ids));
+        Ok((plan, resolved_ids))
     }
 
     /// Parses the given SQL string into a pair of [`CatalogItem`].

src/adapter/src/catalog/state.rs

@@ -2612,7 +2612,7 @@ impl Coordinator {
     /// table.
     #[instrument]
     fn bootstrap_audit_log_table<'a>(
-        &mut self,
+        &self,
         table_id: CatalogItemId,
         name: &'a QualifiedItemName,
         table: &'a Table,

src/adapter/src/coord.rs

@@ -156,7 +156,7 @@ impl Coordinator {
     #[instrument(level = "debug")]
     async fn apply_catalog_implications_inner(
         &mut self,
-        mut ctx: Option<&mut ExecuteContext>,
+        ctx: Option<&mut ExecuteContext>,
         implications: Vec<(CatalogItemId, CatalogImplication)>,
         cluster_commands: Vec<(ClusterId, CatalogImplication)>,
         cluster_replica_commands: Vec<((ClusterId, ReplicaId), CatalogImplication)>,
@@ -203,7 +203,7 @@ impl Coordinator {
             match implication {
                 CatalogImplication::Table(CatalogImplicationKind::Added(table)) => {
                     self.handle_create_table(
-                        &mut ctx,
+                        &ctx,
                         &mut table_collections_to_create,
                         &mut storage_policies_to_initialize,
                         &mut execution_timestamps_to_set,
@@ -900,8 +900,8 @@ impl Coordinator {
 
     #[instrument(level = "debug")]
     async fn handle_create_table(
-        &mut self,
-        ctx: &mut Option<&mut ExecuteContext>,
+        &self,
+        ctx: &Option<&mut ExecuteContext>,
         storage_collections_to_create: &mut BTreeMap<GlobalId, CollectionDescription<Timestamp>>,
         storage_policies_to_initialize: &mut BTreeMap<CompactionWindow, BTreeSet<GlobalId>>,
         execution_timestamps_to_set: &mut BTreeSet<StatementLoggingId>,
@@ -1155,7 +1155,7 @@ impl Coordinator {
 
     #[instrument(level = "debug")]
     async fn handle_create_source(
-        &mut self,
+        &self,
         storage_collections_to_create: &mut BTreeMap<GlobalId, CollectionDescription<Timestamp>>,
         storage_policies_to_initialize: &mut BTreeMap<CompactionWindow, BTreeSet<GlobalId>>,
         item_id: CatalogItemId,

src/adapter/src/coord/catalog_implications.rs

@@ -109,7 +109,7 @@ impl SchedulingDecision {
 impl Coordinator {
     #[mz_ore::instrument(level = "debug")]
     /// Call each scheduling policy.
-    pub(crate) async fn check_scheduling_policies(&mut self) {
+    pub(crate) async fn check_scheduling_policies(&self) {
         // (So far, we have only this one policy.)
         self.check_refresh_policy();
     }

src/adapter/src/coord/cluster_scheduling.rs

@@ -444,7 +444,7 @@ impl Coordinator {
 
     #[mz_ore::instrument(level = "debug")]
     async fn handle_generate_sasl_challenge(
-        &mut self,
+        &self,
         tx: oneshot::Sender<Result<SASLChallengeResponse, AdapterError>>,
         role_name: String,
         client_nonce: String,
@@ -521,7 +521,7 @@ impl Coordinator {
 
     #[mz_ore::instrument(level = "debug")]
     async fn handle_authenticate_password(
-        &mut self,
+        &self,
         tx: oneshot::Sender<Result<AuthResponse, AdapterError>>,
         role_name: String,
         password: Option<Password>,

src/adapter/src/coord/command_handler.rs

@@ -290,7 +290,7 @@ impl Coordinator {
     /// called after this function successfully returns on any built
     /// [`DataflowDesc`](mz_compute_types::dataflows::DataflowDesc).
     #[instrument(name = "coord::catalog_transact_inner")]
-    pub(crate) async fn catalog_transact_inner<'a>(
+    pub(crate) async fn catalog_transact_inner(
         &mut self,
         conn_id: Option<&ConnectionId>,
         ops: Vec<catalog::Op>,

src/adapter/src/coord/ddl.rs

@@ -207,7 +207,7 @@ impl Coordinator {
     }
 
     #[mz_ore::instrument(level = "debug")]
-    pub async fn storage_usage_fetch(&mut self) {
+    pub async fn storage_usage_fetch(&self) {
         let internal_cmd_tx = self.internal_cmd_tx.clone();
         let client = self.storage_usage_client.clone();