Skip to content

Commit a077ea4

Browse files
committed
Formatting
1 parent dc14328 commit a077ea4

3 files changed

Lines changed: 9 additions & 4 deletions

File tree

crates/ndc-sqlserver/src/connector.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,7 @@ impl<Env: Environment + Send + Sync + 'static> connector::ConnectorSetup for SQL
4545
&self,
4646
configuration_dir: &Path,
4747
) -> Result<<Self::Connector as connector::Connector>::Configuration> {
48-
let configuration_file = configuration_dir
49-
.join(configuration::CONFIGURATION_FILENAME);
48+
let configuration_file = configuration_dir.join(configuration::CONFIGURATION_FILENAME);
5049
let configuration_file_contents =
5150
fs::read_to_string(&configuration_file).await.map_err(|_| {
5251
connector::ParseError::CouldNotFindConfiguration(configuration_file.clone())

crates/query-engine/execution/src/mutation.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,10 @@ pub async fn execute_mutations(
185185
let acquisition_timer = metrics.time_connection_acquisition_wait();
186186
let connection_result = mssql_pool
187187
.get()
188-
.instrument(info_span!("Acquire connection", internal.visibility = "user"))
188+
.instrument(info_span!(
189+
"Acquire connection",
190+
internal.visibility = "user"
191+
))
189192
.await
190193
.map_err(Error::ConnectionPool);
191194
let mut connection = acquisition_timer.complete_with(connection_result)?;

crates/query-engine/execution/src/query.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,10 @@ pub async fn mssql_execute_query_plan(
2929
let acquisition_timer = metrics.time_connection_acquisition_wait();
3030
let connection_result = mssql_pool
3131
.get()
32-
.instrument(info_span!("Acquire connection", internal.visibility = "user"))
32+
.instrument(info_span!(
33+
"Acquire connection",
34+
internal.visibility = "user"
35+
))
3336
.await
3437
.map_err(Error::ConnectionPool);
3538
let mut connection = acquisition_timer.complete_with(connection_result)?;

0 commit comments

Comments
 (0)