test: update worker state fixtures
This commit is contained in:
@@ -3761,6 +3761,7 @@ mod completion_flow_tests {
|
|||||||
protocol::WorkerRunState::Running,
|
protocol::WorkerRunState::Running,
|
||||||
)),
|
)),
|
||||||
last_command_id: 0,
|
last_command_id: 0,
|
||||||
|
last_finished_submission_request_id: None,
|
||||||
};
|
};
|
||||||
app.handle_worker_event(Event::WorkerState {
|
app.handle_worker_event(Event::WorkerState {
|
||||||
snapshot: running.clone(),
|
snapshot: running.clone(),
|
||||||
@@ -3780,6 +3781,7 @@ mod completion_flow_tests {
|
|||||||
protocol::WorkerRunState::Running,
|
protocol::WorkerRunState::Running,
|
||||||
)),
|
)),
|
||||||
last_command_id: 2,
|
last_command_id: 2,
|
||||||
|
last_finished_submission_request_id: Some("request-old".to_string()),
|
||||||
};
|
};
|
||||||
app.handle_worker_event(Event::WorkerState {
|
app.handle_worker_event(Event::WorkerState {
|
||||||
snapshot: running.clone(),
|
snapshot: running.clone(),
|
||||||
@@ -3789,6 +3791,7 @@ mod completion_flow_tests {
|
|||||||
let fresh_idle = WorkerStateSnapshot {
|
let fresh_idle = WorkerStateSnapshot {
|
||||||
state: protocol::WorkerState::Idle,
|
state: protocol::WorkerState::Idle,
|
||||||
last_command_id: 0,
|
last_command_id: 0,
|
||||||
|
last_finished_submission_request_id: None,
|
||||||
};
|
};
|
||||||
app.handle_worker_event(Event::WorkerState {
|
app.handle_worker_event(Event::WorkerState {
|
||||||
snapshot: fresh_idle.clone(),
|
snapshot: fresh_idle.clone(),
|
||||||
@@ -3800,6 +3803,7 @@ mod completion_flow_tests {
|
|||||||
protocol::WorkerRunState::Paused,
|
protocol::WorkerRunState::Paused,
|
||||||
)),
|
)),
|
||||||
last_command_id: 3,
|
last_command_id: 3,
|
||||||
|
last_finished_submission_request_id: None,
|
||||||
};
|
};
|
||||||
app.handle_worker_event(Event::CommandAcknowledged {
|
app.handle_worker_event(Event::CommandAcknowledged {
|
||||||
acknowledgement: protocol::WorkerCommandAcknowledgement {
|
acknowledgement: protocol::WorkerCommandAcknowledgement {
|
||||||
|
|||||||
@@ -579,6 +579,7 @@ mod tests {
|
|||||||
protocol::WorkerRunState::Running,
|
protocol::WorkerRunState::Running,
|
||||||
)),
|
)),
|
||||||
last_command_id: 0,
|
last_command_id: 0,
|
||||||
|
last_finished_submission_request_id: None,
|
||||||
}),
|
}),
|
||||||
last_seen_at: None,
|
last_seen_at: None,
|
||||||
pinned: false,
|
pinned: false,
|
||||||
@@ -869,6 +870,7 @@ mod tests {
|
|||||||
short.worker_state = Some(protocol::WorkerStateSnapshot {
|
short.worker_state = Some(protocol::WorkerStateSnapshot {
|
||||||
state: protocol::WorkerState::Idle,
|
state: protocol::WorkerState::Idle,
|
||||||
last_command_id: 0,
|
last_command_id: 0,
|
||||||
|
last_finished_submission_request_id: None,
|
||||||
});
|
});
|
||||||
|
|
||||||
let mut long = worker("runtime-a", "worker-b", None);
|
let mut long = worker("runtime-a", "worker-b", None);
|
||||||
|
|||||||
Reference in New Issue
Block a user