Prefills placeholders in the submit request and creates job ID
(job_id: JobId, submit_desc: &mut JobSubmitDescription, state: &mut State)
| 331 | |
| 332 | /// Prefills placeholders in the submit request and creates job ID |
| 333 | fn prepare_job(job_id: JobId, submit_desc: &mut JobSubmitDescription, state: &mut State) { |
| 334 | // Prefill currently known placeholders eagerly |
| 335 | if let JobTaskDescription::Array { |
| 336 | ref mut task_desc, .. |
| 337 | } = submit_desc.task_desc |
| 338 | { |
| 339 | match &mut task_desc.kind { |
| 340 | TaskKind::ExternalProgram(TaskKindProgram { program, .. }) => { |
| 341 | fill_placeholders_after_submit( |
| 342 | program, |
| 343 | job_id, |
| 344 | &submit_desc.submit_dir, |
| 345 | &state.server_info().server_uid, |
| 346 | ); |
| 347 | } |
| 348 | } |
| 349 | }; |
| 350 | |
| 351 | if let Some(path) = &mut submit_desc.stream_path { |
| 352 | fill_placeholders_log( |
| 353 | path, |
| 354 | job_id, |
| 355 | &submit_desc.submit_dir, |
| 356 | &state.server_info().server_uid, |
| 357 | ); |
| 358 | *path = normalize_path(path.as_path(), &submit_desc.submit_dir); |
| 359 | } |
| 360 | } |
| 361 | |
| 362 | fn serialize_task_body( |
| 363 | task_desc: &TaskDescription, |
no test coverage detected