Run kubernetes plays on the kubernetes worker (#954)

Signed-off-by: Christian Berendt <[email protected]>

osism/commands/apply.py

@@ -11,7 +11,7 @@
 
 from osism.core import enums
 from osism.core.playbooks import MAP_ROLE2ENVIRONMENT, MAP_ROLE2RUNTIME
-from osism.tasks import ansible, ceph, kolla, handle_task
+from osism.tasks import ansible, ceph, kolla, kubernetes, handle_task
 
 
 class Run(Command):
@@ -322,6 +322,12 @@ def _prepare_task(
                 t = ceph.run.si(
                     environment, role, arguments, auto_release_time=task_timeout
                 )
+        elif environment == "kubernetes":
+            if sub:
+                environment = f"{environment}.{sub}"
+            t = kubernetes.run.si(
+                environment, role, arguments, auto_release_time=task_timeout
+            )
         elif role == "loadbalancer-ng":
             if sub:
                 environment = f"{environment}.{sub}"

osism/commands/worker.py

@@ -32,6 +32,7 @@ def take_action(self, parsed_args):
             tasks = queue
         elif queue == "osism-kubernetes":
             tasks = "kubernetes"
+            queue = "kubernetes"
         # kolla-ansible, ceph-ansible, osism-ansible
         else:
             tasks = queue[:-8]