Whatev CI asked me to do

Author: slinkydeveloper

Cargo.lock

@@ -19,7 +19,9 @@ use crate::cli_env::CliEnv;
 use crate::clients::batch_execute;
 use crate::clients::datafusion_helpers::find_active_invocations_simple;
 use crate::clients::{self, AdminClientInterface};
-use crate::commands::invocations::{create_query_filter, DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT};
+use crate::commands::invocations::{
+    DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT, create_query_filter,
+};
 use crate::ui::invocations::render_simple_invocation_list;
 use crate::ui::with_progress;
 

cli/src/commands/invocations/cancel.rs

@@ -13,13 +13,13 @@ use crate::clients::datafusion_helpers::find_active_invocations_simple;
 use crate::clients::{self, AdminClientInterface, batch_execute};
 use crate::ui::invocations::render_simple_invocation_list;
 
+use crate::commands::invocations::DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT;
 use anyhow::{Result, anyhow, bail};
 use cling::prelude::*;
 use comfy_table::{Cell, Color, Table};
 use restate_cli_util::ui::console::{StyledTable, confirm_or_exit};
 use restate_cli_util::{c_indent_table, c_println, c_success, c_warn};
 use restate_types::identifiers::InvocationId;
-use crate::commands::invocations::DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT;
 
 #[derive(Run, Parser, Collect, Clone)]
 #[cling(run = "run_pause")]

cli/src/commands/invocations/pause.rs

@@ -11,7 +11,9 @@
 use crate::cli_env::CliEnv;
 use crate::clients::datafusion_helpers::find_active_invocations_simple;
 use crate::clients::{self, AdminClientInterface, batch_execute};
-use crate::commands::invocations::{create_query_filter, DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT};
+use crate::commands::invocations::{
+    DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT, create_query_filter,
+};
 use crate::ui::invocations::render_simple_invocation_list;
 
 use anyhow::{Result, anyhow, bail};

cli/src/commands/invocations/purge.rs

@@ -13,7 +13,9 @@ use crate::clients::datafusion_helpers::find_active_invocations_simple;
 use crate::clients::{self, AdminClientInterface, batch_execute};
 use crate::ui::invocations::render_simple_invocation_list;
 
-use crate::commands::invocations::{create_query_filter, DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT};
+use crate::commands::invocations::{
+    DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT, create_query_filter,
+};
 use anyhow::{Result, anyhow, bail};
 use cling::prelude::*;
 use comfy_table::{Attribute, Cell, Color, Table};

cli/src/commands/invocations/restart_as_new.rs

@@ -13,7 +13,9 @@ use crate::clients::datafusion_helpers::find_active_invocations_simple;
 use crate::clients::{self, AdminClientInterface, batch_execute};
 use crate::ui::invocations::render_simple_invocation_list;
 
-use crate::commands::invocations::{create_query_filter, DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT};
+use crate::commands::invocations::{
+    DEFAULT_BATCH_INVOCATIONS_OPERATION_LIMIT, create_query_filter,
+};
 use anyhow::{Result, anyhow, bail};
 use cling::prelude::*;
 use comfy_table::{Cell, Color, Table};

cli/src/commands/invocations/resume.rs

@@ -44,6 +44,7 @@ clap_builder = { version = "4", default-features = false, features = ["color", "
 comfy-table = { version = "7" }
 criterion = { version = "0.5", features = ["async_tokio"] }
 crossbeam-epoch = { version = "0.9" }
+crossbeam-utils = { version = "0.8" }
 datafusion-common = { version = "50", default-features = false, features = ["object_store", "recursive_protection"] }
 datafusion-expr = { version = "50", default-features = false, features = ["recursive_protection"] }
 digest = { version = "0.10", features = ["mac", "std"] }
@@ -171,6 +172,7 @@ clap_builder = { version = "4", default-features = false, features = ["color", "
 comfy-table = { version = "7" }
 criterion = { version = "0.5", features = ["async_tokio"] }
 crossbeam-epoch = { version = "0.9" }
+crossbeam-utils = { version = "0.8" }
 datafusion-common = { version = "50", default-features = false, features = ["object_store", "recursive_protection"] }
 datafusion-expr = { version = "50", default-features = false, features = ["recursive_protection"] }
 digest = { version = "0.10", features = ["mac", "std"] }