diff --git a/wfe-core/src/traits/persistence.rs b/wfe-core/src/traits/persistence.rs index 3cafbc8..0022539 100644 --- a/wfe-core/src/traits/persistence.rs +++ b/wfe-core/src/traits/persistence.rs @@ -15,8 +15,7 @@ pub trait WorkflowRepository: Send + Sync { ) -> crate::Result<()>; async fn get_runnable_instances(&self, as_at: DateTime) -> crate::Result>; async fn get_workflow_instance(&self, id: &str) -> crate::Result; - async fn get_workflow_instance_by_name(&self, name: &str) - -> crate::Result; + async fn get_workflow_instance_by_name(&self, name: &str) -> crate::Result; async fn get_workflow_instances(&self, ids: &[String]) -> crate::Result>; /// Atomically allocate the next sequence number for a given workflow diff --git a/wfe/src/host.rs b/wfe/src/host.rs index c29bb23..7dde81d 100644 --- a/wfe/src/host.rs +++ b/wfe/src/host.rs @@ -58,10 +58,7 @@ impl HostContext for HostContextImpl { // child shows up as `{definition_id}-{N}` in lookups and logs. // Sub-workflows always use the default; callers wanting a custom // name should start the parent workflow directly. - let n = self - .persistence - .next_definition_sequence(&def_id) - .await?; + let n = self.persistence.next_definition_sequence(&def_id).await?; instance.name = format!("{def_id}-{n}"); let id = self.persistence.create_new_workflow(&instance).await?; diff --git a/wfectl/src/commands/definitions.rs b/wfectl/src/commands/definitions.rs index 6339171..3763ad5 100644 --- a/wfectl/src/commands/definitions.rs +++ b/wfectl/src/commands/definitions.rs @@ -65,10 +65,7 @@ pub async fn run( .collect(); println!( "{}", - render_table( - &["Name", "ID", "Version", "Steps", "Description"], - &rows - ) + render_table(&["Name", "ID", "Version", "Steps", "Description"], &rows) ); println!("{} definition(s)", resp.definitions.len()); } diff --git a/wfectl/src/main.rs b/wfectl/src/main.rs index 1256eaf..769068c 100644 --- a/wfectl/src/main.rs +++ b/wfectl/src/main.rs @@ -131,9 +131,8 @@ async fn dispatch( Command::Watch(args) => watch::run(args, client).await, Command::Logs(args) => logs::run(args, client).await, Command::SearchLogs(args) => search_logs::run(args, client, format).await, - Command::Login(_) - | Command::Logout(_) - | Command::Whoami(_) - | Command::Validate(_) => unreachable!(), + Command::Login(_) | Command::Logout(_) | Command::Whoami(_) | Command::Validate(_) => { + unreachable!() + } } }