Skip to content

Commit

Permalink
Merge pull request #3917 from zendesk/grosser/wait
Browse files Browse the repository at this point in the history
increase deletion wait times since we now do foreground deletion
  • Loading branch information
grosser committed Jan 23, 2021
2 parents 7500ea6 + 3e323e8 commit 300b31c
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
6 changes: 4 additions & 2 deletions plugins/kubernetes/app/models/kubernetes/resource.rb
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,8 @@ module Kubernetes
# run an example file through `kubectl create/replace/delete -f test.yml -v8`
# and see what it does internally ... simple create/update/delete requests or special magic ?
module Resource
DELETE_BACKOFF = [0.0, 0.1, 0.2, 0.5, 1, 2, 4, 8, 16, 32].freeze # seconds

module PatchReplace
def patch_replace?
!@delete_resource && !server_side_apply? && exist?
Expand Down Expand Up @@ -85,11 +87,11 @@ def revert(previous)

# wait for delete to finish before doing further work so we don't run into duplication errors
# - first wait is 0 since the request itself already took a few ms
# - sum of waits should be ~30s which is the default delete timeout
# - we wait long because deleting a deployment will wait for all its' pods to go away which can take time
def delete
return true unless exist?
request_delete
backoff_wait([0.0, 0.1, 0.2, 0.5, 1, 2, 4, 8, 16], "delete resource") do
backoff_wait(DELETE_BACKOFF, "delete resource") do
expire_resource_cache
return true unless exist?
end
Expand Down
2 changes: 1 addition & 1 deletion plugins/kubernetes/test/models/kubernetes/resource_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,7 @@ def assert_create_and_delete_requests(**args, &block)

it "fails when deletion fails" do
assert_request(:delete, url, to_return: {body: "{}"}) do
tries = 9
tries = Kubernetes::Resource::DELETE_BACKOFF.size
assert_request(:get, url, to_return: {body: "{}"}, times: tries + 1) do
resource.expects(:sleep).times(tries)

Expand Down

0 comments on commit 300b31c

Please sign in to comment.