diff --git a/apps/admin-api/src/service.rs b/apps/admin-api/src/service.rs
index dc70f92..06ae6e2 100644
--- a/apps/admin-api/src/service.rs
+++ b/apps/admin-api/src/service.rs
@@ -2024,11 +2024,7 @@ impl AdminService {
         request_id: &str,
     ) -> Result<TestRunResult, ApiError> {
         let runtime_request_context = RuntimeRequestContext::from_request_id(request_id)
-            .with_metering_context(
-                workspace_id.clone(),
-                None,
-                InvocationSource::AdminTestRun,
-            );
+            .with_metering_context(workspace_id.clone(), None, InvocationSource::AdminTestRun);
         let record = self
             .get_operation_version(workspace_id, operation_id, payload.version)
             .await?;
diff --git a/crates/crank-core/src/ext/protocol.rs b/crates/crank-core/src/ext/protocol.rs
index bfe648d..fd1ee3d 100644
--- a/crates/crank-core/src/ext/protocol.rs
+++ b/crates/crank-core/src/ext/protocol.rs
@@ -4,7 +4,9 @@ use async_trait::async_trait;
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
 
-use crate::{AgentId, ExecutionMode, InvocationSource, Protocol, StreamSession, Target, WorkspaceId};
+use crate::{
+    AgentId, ExecutionMode, InvocationSource, Protocol, StreamSession, Target, WorkspaceId,
+};
 
 #[derive(Clone, Debug, PartialEq, Eq, Default)]
 pub struct ResponseCacheScope {
diff --git a/crates/crank-core/src/ext/tenancy.rs b/crates/crank-core/src/ext/tenancy.rs
index 70668ad..fbb20e6 100644
--- a/crates/crank-core/src/ext/tenancy.rs
+++ b/crates/crank-core/src/ext/tenancy.rs
@@ -46,10 +46,7 @@ impl Default for SingleTenantController {
 
 #[async_trait]
 impl TenantController for SingleTenantController {
-    fn resolve_tenant(
-        &self,
-        _request: &TenantResolutionContext,
-    ) -> Result<TenantId, TenancyError> {
+    fn resolve_tenant(&self, _request: &TenantResolutionContext) -> Result<TenantId, TenancyError> {
         Ok(self.tenant_id.clone())
     }
 
@@ -73,7 +70,10 @@ mod tests {
         let tenant = controller
             .resolve_tenant(&TenantResolutionContext::default())
             .unwrap();
-        let workspaces = controller.list_workspaces_for_tenant(&tenant).await.unwrap();
+        let workspaces = controller
+            .list_workspaces_for_tenant(&tenant)
+            .await
+            .unwrap();
 
         assert_eq!(tenant, TenantId::new("default"));
         assert!(workspaces.is_empty());
diff --git a/crates/crank-core/src/lib.rs b/crates/crank-core/src/lib.rs
index 5732cbc..558b541 100644
--- a/crates/crank-core/src/lib.rs
+++ b/crates/crank-core/src/lib.rs
@@ -53,13 +53,13 @@ pub use ext::billing::{
 pub use ext::capability::{CapabilityProfile, CommunityCapabilityProfile};
 pub use ext::metering::{MeteringEvent, MeteringSink, NoopMeteringSink, SharedMeteringSink};
 pub use ext::protocol::{
-    AdapterRegistry, AdapterResponse, PreparedRequest, ProtocolAdapter, ProtocolAdapterError,
-    MeteringContext, ResponseCacheScope, RuntimeRequestContext, SharedProtocolAdapter,
+    AdapterRegistry, AdapterResponse, MeteringContext, PreparedRequest, ProtocolAdapter,
+    ProtocolAdapterError, ResponseCacheScope, RuntimeRequestContext, SharedProtocolAdapter,
     WindowExecutionResult,
 };
 pub use ext::tenancy::{
-    SharedTenantController, SingleTenantController, TenantController, TenantResolutionContext,
-    TenancyError,
+    SharedTenantController, SingleTenantController, TenancyError, TenantController,
+    TenantResolutionContext,
 };
 pub use ids::{
     AgentId, AsyncJobId, AuditEventId, AuthProfileId, DescriptorId, InvitationId, InvocationLogId,
diff --git a/crates/crank-runtime/src/cache_factory.rs b/crates/crank-runtime/src/cache_factory.rs
index 2faa214..e5c5c95 100644
--- a/crates/crank-runtime/src/cache_factory.rs
+++ b/crates/crank-runtime/src/cache_factory.rs
@@ -2,9 +2,7 @@ use std::sync::Arc;
 
 use async_trait::async_trait;
 
-use crate::{
-    RuntimeCacheConfig, RuntimeCacheStoreInitError, RuntimeCacheStores,
-};
+use crate::{RuntimeCacheConfig, RuntimeCacheStoreInitError, RuntimeCacheStores};
 
 #[async_trait]
 pub trait CacheBackendFactory: Send + Sync {
diff --git a/crates/crank-runtime/src/executor.rs b/crates/crank-runtime/src/executor.rs
index 05424e7..a850267 100644
--- a/crates/crank-runtime/src/executor.rs
+++ b/crates/crank-runtime/src/executor.rs
@@ -323,7 +323,8 @@ impl RuntimeExecutor {
         result: &Result<T, RuntimeError>,
         started_at: Instant,
     ) {
-        let Some(context) = request_context.and_then(RuntimeRequestContext::metering_context) else {
+        let Some(context) = request_context.and_then(RuntimeRequestContext::metering_context)
+        else {
             return;
         };