Skip to content

Commit

Permalink
Wait for old deploy jobs to be deleted
Browse files Browse the repository at this point in the history
Keep trying to get the job until it no longer exists
  • Loading branch information
milesgranger committed Oct 30, 2019
1 parent 29c88b7 commit 14716b5
Showing 1 changed file with 18 additions and 3 deletions.
21 changes: 18 additions & 3 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -326,11 +326,26 @@ pub(crate) fn remove_gordo_deploy_jobs(gordo: &Gordo, client: &APIClient, namesp
.iter()
.filter(|job| job.metadata.labels.get("gordoProjectName") == Some(&gordo.metadata.name))
.for_each(|job| {
if let Err(err) = jobs.delete(&job.metadata.name, &DeleteParams::default()) {
error!(
match jobs.delete(&job.metadata.name, &DeleteParams::default()) {
Ok(_) => {
info!(
"Successfully requested to delete job: {}, waiting for it to die.",
&job.metadata.name
);

// Keep trying to get the job, it will fail when it no longer exists.
while let Ok(job) = jobs.get(&job.metadata.name) {
info!(
"Got job resourceVersion: {:#?}, generation: {:#?} waiting for it to be deleted.",
job.metadata.resourceVersion, job.metadata.generation
);
std::thread::sleep(std::time::Duration::from_secs(1));
}
}
Err(err) => error!(
"Failed to delete old gordo job: '{}' with error: {:?}",
&job.metadata.name, err
)
),
}
}),
Err(e) => error!("Failed to list jobs: {:?}", e),
Expand Down

0 comments on commit 14716b5

Please sign in to comment.