MCPcopy Create free account
hub / github.com/It4innovations/hyperqueue / handle_open_job

Function handle_open_job

crates/hyperqueue/src/server/client/submit.rs:502–514  ·  view source on GitHub ↗
(
    state_ref: &StateRef,
    senders: &Senders,
    job_description: JobDescription,
)

Source from the content-addressed store, hash-verified

500}
501
502pub(crate) fn handle_open_job(
503 state_ref: &StateRef,
504 senders: &Senders,
505 job_description: JobDescription,
506) -> ToClientMessage {
507 let job_id = state_ref.get_mut().new_job_id();
508 senders
509 .events
510 .on_job_opened(job_id, job_description.clone());
511 let job = Job::new(job_id, job_description, true);
512 state_ref.get_mut().add_job(job);
513 ToClientMessage::OpenJobResponse(OpenJobResponse { job_id })
514}
515
516#[cfg(test)]
517mod tests {

Callers 1

client_rpc_loopFunction · 0.85

Calls 6

OpenJobResponseClass · 0.85
new_job_idMethod · 0.80
on_job_openedMethod · 0.80
get_mutMethod · 0.45
cloneMethod · 0.45
add_jobMethod · 0.45

Tested by

no test coverage detected