Fix resolving k8s pending queue may cause a queue with a uuid name to be created

README.md

@@ -197,7 +197,7 @@ with `--cpu-only`).
 
 If no flag is set, and `NVIDIA_VISIBLE_DEVICES` variable doesn't exist, all GPU's will be allocated for
 the `clearml-agent` <br>
-If `--cpu-only` flag is set, or `NVIDIA_VISIBLE_DEVICES="none"`, no gpu will be allocated for
+If `--cpu-only` flag is set, or `NVIDIA_VISIBLE_DEVICES` is an empty string (""), no gpu will be allocated for
 the `clearml-agent`
 
 Example: spin two agents, one per gpu on the same machine:

clearml_agent/commands/worker.py

@@ -1379,9 +1379,6 @@ class Worker(ServiceCommandSection):
 
         self._session.print_configuration()
 
-    def resolve_daemon_queue_names(self, queues, create_if_missing=False):
-        return self._resolve_queue_names(queues=queues, create_if_missing=create_if_missing)
-
     def daemon(self, queues, log_level, foreground=False, docker=False, detached=False, order_fairness=False, **kwargs):
         self._apply_extra_configuration()
 
@@ -1424,7 +1421,7 @@ class Worker(ServiceCommandSection):
 
         # if we do not need to create queues, make sure they are valid
         # match previous behaviour when we validated queue names before everything else
-        queues = self.resolve_daemon_queue_names(queues, create_if_missing=kwargs.get('create_queue', False))
+        queues = self._resolve_queue_names(queues, create_if_missing=kwargs.get('create_queue', False))
 
         queues_info = [
             q.to_dict()

clearml_agent/glue/k8s.py

@@ -11,7 +11,6 @@ import subprocess
 import tempfile
 from copy import deepcopy
 from pathlib import Path
-from pprint import pformat
 from threading import Thread
 from time import sleep
 from typing import Text, List, Callable, Any, Collection, Optional, Union
@@ -681,8 +680,6 @@ class K8sIntegration(Worker):
         with open(yaml_file, 'wt') as f:
             yaml.dump(template, f)
 
-        self.log.debug("Applying template:\n{}".format(pformat(template, indent=2)))
-
         kubectl_cmd = self.KUBECTL_APPLY_CMD.format(
             task_id=task_id,
             docker_image=docker_image,