Skip to content

Commit 64a9bfd

Browse files
committed
lint
1 parent dfb0137 commit 64a9bfd

2 files changed

Lines changed: 5 additions & 14 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -334,7 +334,7 @@ async fn activity_id_or_type_change_is_nondeterministic(
334334
} else {
335335
canned_histories::single_activity("1")
336336
};
337-
t.set_flags_first_wft(&[CoreInternalFlags::IdAndTypeDeterminismChecks as u32], &[]);
337+
t.set_flags_first_wft(&[CoreInternalFlags::IdAndTypeDeterminismChecks], &[]);
338338
t.set_wf_input((id_change, local_act).as_json_payload().unwrap());
339339
let mock = mock_worker_client();
340340
let mut mh = MockPollCfg::from_resp_batches(
@@ -417,7 +417,7 @@ async fn child_wf_id_or_type_change_is_nondeterministic(
417417
let wf_id = "fakeid";
418418
let wf_type = DEFAULT_WORKFLOW_TYPE;
419419
let mut t = canned_histories::single_child_workflow("1");
420-
t.set_flags_first_wft(&[CoreInternalFlags::IdAndTypeDeterminismChecks as u32], &[]);
420+
t.set_flags_first_wft(&[CoreInternalFlags::IdAndTypeDeterminismChecks], &[]);
421421
t.set_wf_input(id_change.as_json_payload().unwrap());
422422
let mock = mock_worker_client();
423423
let mut mh = MockPollCfg::from_resp_batches(

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

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -346,10 +346,7 @@ fn patch_marker_single_activity(
346346
let mut t = TestHistoryBuilder::default();
347347
t.add_by_type(EventType::WorkflowExecutionStarted);
348348
t.add_full_wf_task();
349-
t.set_flags_first_wft(
350-
&[CoreInternalFlags::UpsertSearchAttributeOnPatch as u32],
351-
&[],
352-
);
349+
t.set_flags_first_wft(&[CoreInternalFlags::UpsertSearchAttributeOnPatch], &[]);
353350
match marker_type {
354351
MarkerType::Deprecated => {
355352
t.add_has_change_marker(MY_PATCH_ID, true);
@@ -720,10 +717,7 @@ async fn same_change_multiple_spots(#[case] have_marker_in_hist: bool, #[case] r
720717
let mut t = TestHistoryBuilder::default();
721718
t.add_by_type(EventType::WorkflowExecutionStarted);
722719
t.add_full_wf_task();
723-
t.set_flags_first_wft(
724-
&[CoreInternalFlags::UpsertSearchAttributeOnPatch as u32],
725-
&[],
726-
);
720+
t.set_flags_first_wft(&[CoreInternalFlags::UpsertSearchAttributeOnPatch], &[]);
727721
if have_marker_in_hist {
728722
t.add_has_change_marker(MY_PATCH_ID, false);
729723
t.add_upsert_search_attrs_for_patch(&[MY_PATCH_ID.to_string()]);
@@ -830,10 +824,7 @@ async fn many_patches_combine_in_search_attrib_update(#[case] num_patches: usize
830824
let mut t = TestHistoryBuilder::default();
831825
t.add_by_type(EventType::WorkflowExecutionStarted);
832826
t.add_full_wf_task();
833-
t.set_flags_first_wft(
834-
&[CoreInternalFlags::UpsertSearchAttributeOnPatch as u32],
835-
&[],
836-
);
827+
t.set_flags_first_wft(&[CoreInternalFlags::UpsertSearchAttributeOnPatch], &[]);
837828
for i in 1..=num_patches {
838829
let id = format!("patch-{i}");
839830
t.add_has_change_marker(&id, false);

0 commit comments

Comments
 (0)