Skip to content

Commit 6cb8c89

Browse files
committed
fmt
1 parent 377364a commit 6cb8c89

File tree

4 files changed

+8
-15
lines changed

4 files changed

+8
-15
lines changed

bottlecap/src/bin/bottlecap/main.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -825,8 +825,7 @@ async fn handle_event_bus_event(
825825
debug!("Telemetry event received: {:?}", event);
826826
match event.record {
827827
TelemetryRecord::PlatformInitStart {
828-
runtime_version,
829-
..
828+
runtime_version, ..
830829
} => {
831830
if let Err(e) = invocation_processor_handle
832831
.on_platform_init_start(event.time, runtime_version)

bottlecap/src/flushing/service.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -107,9 +107,7 @@ impl FlushingService {
107107
for sketch in &sketch_payload.sketches {
108108
debug!(
109109
"FLUSHING_SERVICE | sketch batch[{}]: metric='{}' tags={:?}",
110-
i,
111-
sketch.metric,
112-
sketch.tags
110+
i, sketch.metric, sketch.tags
113111
);
114112
}
115113
}

bottlecap/src/lifecycle/invocation/processor.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1725,10 +1725,7 @@ mod tests {
17251725
let mut processor = setup();
17261726
let time = Utc::now();
17271727

1728-
processor.on_platform_init_start(
1729-
time,
1730-
Some("python:3.14.DurableFunction.v6".to_string()),
1731-
);
1728+
processor.on_platform_init_start(time, Some("python:3.14.DurableFunction.v6".to_string()));
17321729

17331730
let now: i64 = std::time::UNIX_EPOCH
17341731
.elapsed()

bottlecap/src/metrics/enhanced/lambda.rs

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -867,14 +867,13 @@ mod tests {
867867
let ts = (now / 10) * 10;
868868
let durable_tags = SortedTags::parse("durable_function:true").ok();
869869
let entry = metrics_aggr
870-
.get_entry_by_id(
871-
constants::INVOCATIONS_METRIC.into(),
872-
durable_tags,
873-
ts,
874-
)
870+
.get_entry_by_id(constants::INVOCATIONS_METRIC.into(), durable_tags, ts)
875871
.await
876872
.unwrap();
877-
assert!(entry.is_some(), "Expected metric with durable_function:true tag");
873+
assert!(
874+
entry.is_some(),
875+
"Expected metric with durable_function:true tag"
876+
);
878877
}
879878

880879
#[tokio::test]

0 commit comments

Comments
 (0)