github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

Revert "Bugfix for erroneous upgrade needed messaging in kubernetes worker charm."

Browse Source 
This reverts commit 21b63cc1f2.
This commit is contained in:
George Kraft 2018-04-11 15:21:02 -05:00
parent 666b6b9e85
commit 1e5cfc56c8
1 changed files with 8 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
cluster/juju/layers/kubernetes-worker/reactive/kubernetes_worker.py
View File

@ -85,22 +85,20 @@ def upgrade_charm():
set_state('kubernetes-worker.restart-needed')
def get_snap_resource_paths():
resources = ['kubectl', 'kubelet', 'kube-proxy']
return [hookenv.resource_get(resource) for resource in resources]
def check_resources_for_upgrade_needed():
hookenv.status_set('maintenance', 'Checking resources')
if any_file_changed(get_snap_resource_paths()):
resources = ['kubectl', 'kubelet', 'kube-proxy']
paths = [hookenv.resource_get(resource) for resource in resources]
if any_file_changed(paths):
set_upgrade_needed()
def set_upgrade_needed():
set_state('kubernetes-worker.snaps.upgrade-needed')
config = hookenv.config()
previous_channel = config.previous('channel')
require_manual = config.get('require-manual-upgrade')
if not require_manual:
if previous_channel is None or not require_manual:
set_state('kubernetes-worker.snaps.upgrade-specified')
@ -136,34 +134,21 @@ def cleanup_pre_snap_services():
os.remove(file)
@when_not('kubernetes-worker.snap.resources-available')
def check_snap_resources():
for path in get_snap_resource_paths():
if not path or not os.path.exists(path):
msg = 'Missing snap resources.'
hookenv.status_set('blocked', msg)
return
set_state('kubernetes-worker.snap.resources-available')
set_state('kubernetes-worker.snaps.upgrade-specified')
@when('config.changed.channel')
def channel_changed():
set_upgrade_needed()
@when('kubernetes-worker.snaps.upgrade-needed',
'kubernetes-worker.snap.resources-available')
@when('kubernetes-worker.snaps.upgrade-needed')
@when_not('kubernetes-worker.snaps.upgrade-specified')
def upgrade_needed_status():
msg = 'Needs manual upgrade, run the upgrade action'
hookenv.status_set('blocked', msg)
@when('kubernetes-worker.snap.resources-available',
'kubernetes-worker.snaps.upgrade-specified')
@when('kubernetes-worker.snaps.upgrade-specified')
def install_snaps():
any_file_changed(get_snap_resource_paths())
check_resources_for_upgrade_needed()
channel = hookenv.config('channel')
hookenv.status_set('maintenance', 'Installing kubectl snap')
snap.install('kubectl', channel=channel, classic=True)