fix integration tests

temporalio · Nov 21, 2024 · 6b075c1 · 6b075c1
1 parent 6da7a69
commit 6b075c1
Show file tree

Hide file tree

Showing 7 changed files with 14 additions and 1 deletion.
diff --git a/core/src/core_tests/activity_tasks.rs b/core/src/core_tests/activity_tasks.rs
@@ -1191,7 +1191,6 @@ async fn activities_must_be_flushed_to_server_on_shutdown(#[values(true, false)]
 
 #[tokio::test]
 async fn pass_activity_summary_to_metadata() {
-    crate::telemetry::test_telem_console();
     let t = canned_histories::single_activity("1");
     let mut mock_cfg = MockPollCfg::from_hist_builder(t);
     let wf_id = mock_cfg.hists[0].wf_id.clone();

diff --git a/tests/integ_tests/polling_tests.rs b/tests/integ_tests/polling_tests.rs
@@ -41,6 +41,7 @@ async fn out_of_order_completion_doesnt_hang() {
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
         ]

diff --git a/tests/integ_tests/queries_tests.rs b/tests/integ_tests/queries_tests.rs
@@ -29,11 +29,13 @@ async fn simple_query_legacy() {
             StartTimer {
                 seq: 0,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(500))),
+                summary: None,
             }
             .into(),
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_secs(3))),
+                summary: None,
             }
             .into(),
         ],

diff --git a/tests/integ_tests/workflow_tests.rs b/tests/integ_tests/workflow_tests.rs
@@ -248,6 +248,7 @@ async fn fail_wf_task(#[values(true, false)] replay: bool) {
         vec![StartTimer {
             seq: 0,
             start_to_fire_timeout: Some(prost_dur!(from_millis(200))),
+            summary: None,
         }
         .into()],
     ))
@@ -372,6 +373,7 @@ async fn signal_workflow_signal_not_handled_on_workflow_completion() {
             vec![StartTimer {
                 seq: 0,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(10))),
+                summary: None,
             }
             .into()],
         ))

diff --git a/tests/integ_tests/workflow_tests/activities.rs b/tests/integ_tests/workflow_tests/activities.rs
@@ -360,6 +360,7 @@ async fn activity_cancellation_try_cancel() {
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
         ]
@@ -417,6 +418,7 @@ async fn activity_cancellation_plus_complete_doesnt_double_resolve() {
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
         ]
@@ -461,6 +463,7 @@ async fn activity_cancellation_plus_complete_doesnt_double_resolve() {
         vec![StartTimer {
             seq: 2,
             start_to_fire_timeout: Some(prost_dur!(from_millis(100))),
+            summary: None,
         }
         .into()],
     ))
@@ -559,6 +562,7 @@ async fn activity_cancellation_wait_cancellation_completed() {
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
         ]
@@ -621,6 +625,7 @@ async fn activity_cancellation_abandon() {
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
         ]

diff --git a/tests/integ_tests/workflow_tests/replay.rs b/tests/integ_tests/workflow_tests/replay.rs
@@ -42,6 +42,7 @@ async fn timer_workflow_replay() {
         vec![StartTimer {
             seq: 0,
             start_to_fire_timeout: Some(prost_dur!(from_secs(1))),
+            summary: None,
         }
         .into()],
     ))

diff --git a/tests/integ_tests/workflow_tests/timers.rs b/tests/integ_tests/workflow_tests/timers.rs
@@ -38,6 +38,7 @@ async fn timer_workflow_manual() {
         vec![StartTimer {
             seq: 0,
             start_to_fire_timeout: Some(prost_dur!(from_secs(1))),
+            summary: None,
         }
         .into()],
     ))
@@ -60,11 +61,13 @@ async fn timer_cancel_workflow() {
             StartTimer {
                 seq: 0,
                 start_to_fire_timeout: Some(prost_dur!(from_millis(50))),
+                summary: None,
             }
             .into(),
             StartTimer {
                 seq: 1,
                 start_to_fire_timeout: Some(prost_dur!(from_secs(10))),
+                summary: None,
             }
             .into(),
         ],