style: apply rustfmt

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(
+            .with_metering_context(workspace_id.clone(), None, InvocationSource::AdminTestRun);
-                workspace_id.clone(),
-                None,
-                InvocationSource::AdminTestRun,
-            );
         let record = self
             .get_operation_version(workspace_id, operation_id, payload.version)
             .await?;

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 {

crates/crank-core/src/ext/tenancy.rs

@@ -46,10 +46,7 @@ impl Default for SingleTenantController {
 
 #[async_trait]
 impl TenantController for SingleTenantController {
-    fn resolve_tenant(
+    fn resolve_tenant(&self, _request: &TenantResolutionContext) -> Result<TenantId, TenancyError> {
-        &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());

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,
+    AdapterRegistry, AdapterResponse, MeteringContext, PreparedRequest, ProtocolAdapter,
-    MeteringContext, ResponseCacheScope, RuntimeRequestContext, SharedProtocolAdapter,
+    ProtocolAdapterError, ResponseCacheScope, RuntimeRequestContext, SharedProtocolAdapter,
     WindowExecutionResult,
 };
 pub use ext::tenancy::{
-    SharedTenantController, SingleTenantController, TenantController, TenantResolutionContext,
+    SharedTenantController, SingleTenantController, TenancyError, TenantController,
-    TenancyError,
+    TenantResolutionContext,
 };
 pub use ids::{
     AgentId, AsyncJobId, AuditEventId, AuthProfileId, DescriptorId, InvitationId, InvocationLogId,

crates/crank-runtime/src/cache_factory.rs

@@ -2,9 +2,7 @@ use std::sync::Arc;
 
 use async_trait::async_trait;
 
-use crate::{
+use crate::{RuntimeCacheConfig, RuntimeCacheStoreInitError, RuntimeCacheStores};
-    RuntimeCacheConfig, RuntimeCacheStoreInitError, RuntimeCacheStores,
-};
 
 #[async_trait]
 pub trait CacheBackendFactory: Send + Sync {

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;
         };