Skip to content

Commit c203e9d

Browse files
committed
fix tests
1 parent 673d06f commit c203e9d

File tree

2 files changed

+13
-7
lines changed

2 files changed

+13
-7
lines changed

src/factotum/executor/tests.rs

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,8 @@ fn execute_sends_started_msg() {
143143
execute_factfile(&ff,
144144
None,
145145
execution_strategy::execute_simulation,
146-
Some(tx.clone()));
146+
Some(tx.clone()),
147+
None);
147148

148149
let expected_starting = rx.recv_timeout(Duration::from_millis(300)).unwrap();
149150

@@ -194,7 +195,8 @@ fn execute_sends_running_messages() {
194195
execute_factfile(&ff,
195196
None,
196197
execution_strategy::execute_simulation,
197-
Some(tx.clone()));
198+
Some(tx.clone()),
199+
None);
198200

199201
println!("Expecting {} messages..", total_expected_task_updates);
200202

@@ -267,7 +269,8 @@ fn execute_sends_updates_for_skipped_fail() {
267269
execute_factfile(&ff,
268270
None,
269271
execution_strategy::execute_simulation,
270-
Some(tx.clone()));
272+
Some(tx.clone()),
273+
None);
271274

272275
let mut recv_msg = vec![];
273276

@@ -358,7 +361,8 @@ fn execute_sends_failed_skipped_messages() {
358361
execute_factfile(&ff,
359362
None,
360363
execution_strategy::execute_simulation,
361-
Some(tx.clone()));
364+
Some(tx.clone()),
365+
None);
362366

363367
let mut recv_msg = vec![];
364368

@@ -489,7 +493,8 @@ fn execute_sends_updates_for_skipped_noop() {
489493
execute_factfile(&ff,
490494
None,
491495
execution_strategy::execute_simulation,
492-
Some(tx.clone()));
496+
Some(tx.clone()),
497+
None);
493498

494499
let mut recv_msg = vec![];
495500

@@ -580,7 +585,8 @@ fn execute_sends_noop_skipped_messages() {
580585
execute_factfile(&ff,
581586
None,
582587
execution_strategy::execute_simulation,
583-
Some(tx.clone()));
588+
Some(tx.clone()),
589+
None);
584590

585591
let mut recv_msg = vec![];
586592

src/factotum/webhook/jobupdate/tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ fn to_json_valid_against_schema_task_transition_waiting_to_running() {
141141
fn to_task_states_empty() {
142142
let empty = vec![];
143143
let max_stdouterr_size: usize = 10_000;
144-
assert!(JobUpdate::to_task_states(&empty, &max_stdouterr_size).is_empty());
144+
assert!(JobUpdate::to_task_states(&empty, &max_stdouterr_size, None).is_empty());
145145
}
146146

147147
#[test]

0 commit comments

Comments
 (0)