Format

Author: mjameswh

crates/sdk-core/src/core_tests/workflow_cancels.rs

@@ -10,7 +10,9 @@ use rstest::rstest;
 use std::time::Duration;
 use temporalio_common::protos::coresdk::{
     workflow_activation::{WorkflowActivationJob, workflow_activation_job},
-    workflow_commands::{CancelWorkflowExecution, CompleteWorkflowExecution, FailWorkflowExecution},
+    workflow_commands::{
+        CancelWorkflowExecution, CompleteWorkflowExecution, FailWorkflowExecution,
+    },
 };
 
 enum CompletionType {

crates/sdk-core/src/replay/canned_histories.rs

@@ -1,4 +1,7 @@
 use crate::replay::TestHistoryBuilder;
+use prost::Message;
+use rand::Rng;
+use std::{fs::File, io::Write, path::PathBuf};
 use temporalio_common::protos::{
     coresdk::common::NamespacedWorkflowExecution,
     temporal::api::{
@@ -8,9 +11,6 @@ use temporalio_common::protos::{
         history::v1::*,
     },
 };
-use prost::Message;
-use rand::Rng;
-use std::{fs::File, io::Write, path::PathBuf};
 
 ///  1: EVENT_TYPE_WORKFLOW_EXECUTION_STARTED
 ///  2: EVENT_TYPE_WORKFLOW_TASK_SCHEDULED

crates/sdk-core/src/replay/history_builder.rs

@@ -1,4 +1,10 @@
 use crate::replay::HistoryInfo;
+use anyhow::bail;
+use prost_types::Timestamp;
+use std::{
+    collections::HashMap,
+    time::{Duration, SystemTime},
+};
 use temporalio_common::protos::{
     constants::{LOCAL_ACTIVITY_MARKER_NAME, PATCH_MARKER_NAME},
     coresdk::{
@@ -22,12 +28,6 @@ use temporalio_common::protos::{
         update::v1::outcome,
     },
 };
-use anyhow::bail;
-use prost_types::Timestamp;
-use std::{
-    collections::HashMap,
-    time::{Duration, SystemTime},
-};
 use uuid::Uuid;
 
 /// The workflow type name used by default in test histories.

crates/sdk-core/src/replay/history_info.rs

@@ -1,12 +1,12 @@
+use anyhow::{anyhow, bail};
+use rand::random;
 use temporalio_common::protos::temporal::api::{
     common::v1::WorkflowType,
     enums::v1::{EventType, TaskQueueKind},
     history::v1::{History, HistoryEvent, WorkflowExecutionStartedEventAttributes, history_event},
     taskqueue::v1::TaskQueue,
     workflowservice::v1::{GetWorkflowExecutionHistoryResponse, PollWorkflowTaskQueueResponse},
 };
-use anyhow::{anyhow, bail};
-use rand::random;
 
 /// Contains information about a validated history. Used for replay and other testing.
 #[derive(Clone, Debug, PartialEq)]

crates/sdk-core/tests/integ_tests/workflow_tests.rs

@@ -70,7 +70,9 @@ use temporalio_sdk::{
 use temporalio_sdk_core::{
     CoreRuntime, PollError, PollerBehavior, TunerHolder, WorkflowErrorType, prost_dur,
     replay::{DEFAULT_WORKFLOW_TYPE, HistoryForReplay, canned_histories},
-    test_help::{MockPollCfg, WorkerTestHelpers, drain_pollers_and_shutdown, schedule_activity_cmd},
+    test_help::{
+        MockPollCfg, WorkerTestHelpers, drain_pollers_and_shutdown, schedule_activity_cmd,
+    },
 };
 use tokio::{join, sync::Notify, time::sleep};
 use tonic::IntoRequest;

crates/sdk-core/tests/integ_tests/workflow_tests/replay.rs

@@ -24,7 +24,8 @@ use temporalio_sdk::{
 use temporalio_sdk_core::{
     PollError, prost_dur,
     replay::{
-        DEFAULT_WORKFLOW_TYPE, HistoryFeeder, HistoryForReplay, TestHistoryBuilder, canned_histories,
+        DEFAULT_WORKFLOW_TYPE, HistoryFeeder, HistoryForReplay, TestHistoryBuilder,
+        canned_histories,
     },
     test_help::{MockPollCfg, ResponseType, WorkerTestHelpers},
 };