Fixed Python 2.7 support, refactor, PEP8

clearml/__init__.py

@@ -8,11 +8,11 @@ from .logger import Logger
 from .storage import StorageManager
 from .errors import UsageError
 from .datasets import Dataset
-from .backend_api import browser_login
 
 TaskTypes = Task.TaskTypes
 
 if not PY2:
+    from .backend_api import browser_login  # noqa: F401
     from .automation.controller import PipelineController, PipelineDecorator  # noqa: F401
 
     __all__ = [

clearml/backend_api/session/defs.py

@@ -38,12 +38,13 @@ for a very long time for a non-responding or mis-configured server
 ENV_API_EXTRA_RETRY_CODES = EnvEntry("CLEARML_API_EXTRA_RETRY_CODES")
 
 
-class MissingConfigError(Exception):
+class MissingConfigError(ValueError):
     def __init__(self, message=None):
         if message is None:
             message = (
                 "It seems ClearML is not configured on this machine!\n"
-                "To get started with ClearML, setup your own 'clearml-server' or create a free account at https://app.clear.ml\n"
-                "Setup instructions can be found here: https://clear.ml/docs/latest/docs"
+                "To get started with ClearML, setup your own 'clearml-server' or "
+                "create a free account at https://app.clear.ml\n"
+                "Setup instructions can be found here: https://clear.ml/docs"
             )
-        super().__init__(message)
+        super(MissingConfigError, self).__init__(message)

clearml/backend_api/session/session.py

@@ -915,7 +915,8 @@ def browser_login(clearml_server=None):
 
     print("")
     if counter:
-        print("\nHurrah! \N{FACE WITH PARTY HORN AND PARTY HAT} \N{CONFETTI BALL} \N{party popper}")
+        # these emojis actually requires python 3.6+
+        print("\nHurrah! \N{face with party horn and party hat} \N{confetti ball} \N{party popper}")  # noqa: E999
 
     if token:
         # set Token

clearml/storage/manager.py

@@ -5,7 +5,7 @@ import tarfile
 from multiprocessing.pool import ThreadPool
 from random import random
 from time import time
-from typing import List, Optional
+from typing import List, Optional, Union
 from zipfile import ZipFile
 from six.moves.urllib.parse import urlparse
 
@@ -426,7 +426,7 @@ class StorageManager(object):
 
     @classmethod
     def list(cls, remote_url, return_full_path=False, with_metadata=False):
-        # type: (str, bool) -> Optional[List[Union[str, dict]]]
+        # type: (str, bool, bool) -> Optional[List[Union[str, dict]]]
         """
         Return a list of object names inside the base path or dictionaries containing the corresponding
         objects' metadata (in case `with_metadata` is True)

clearml/task.py

@@ -16,7 +16,7 @@ try:
     # noinspection PyCompatibility
     from collections.abc import Sequence as CollectionsSequence
 except ImportError:
-    from collections import Sequence as CollectionsSequence
+    from collections import Sequence as CollectionsSequence  # noqa
 
 from typing import (
     Optional,
@@ -92,7 +92,7 @@ from .binding.args import (
 from .utilities.dicts import ReadOnlyDict, merge_dicts
 from .utilities.proxy_object import (
     ProxyDictPreWrite, ProxyDictPostWrite, flatten_dictionary,
-    nested_from_flat_dictionary, naive_nested_from_flat_dictionary, )
+    nested_from_flat_dictionary, naive_nested_from_flat_dictionary, StubObject as _TaskStub)
 from .utilities.resource_monitor import ResourceMonitor
 from .utilities.seed import make_deterministic
 from .utilities.lowlevel.threads import get_current_thread_id
@@ -605,7 +605,9 @@ class Task(_Task):
                         if not ENV_IGNORE_MISSING_CONFIG.get():
                             raise
                         getLogger().warning(str(e))
-                        return _TaskStub()
+                        # return a Task-stub instead of the original class
+                        # this will make sure users can still call the Stub without code breaking
+                        return _TaskStub()  # noqa
                     # set defaults
                     if cls._offline_mode:
                         task.output_uri = None
@@ -1932,10 +1934,11 @@ class Task(_Task):
         - In case the ``serialization_function`` argument is set - any extension is supported
 
         :param Callable[Any, Union[bytes, bytearray]] serialization_function: A serialization function that takes one
-            parameter of any types which is the object to be serialized. The function should return a `bytes` or `bytearray`
-            object, which represents the serialized object. Note that the object will be immediately serialized using this function,
-            thus other serialization methods will not be used (e.g. `pandas.DataFrame.to_csv`), even if possible.
-            To deserialize this artifact when getting it using the `Artifact.get` method, use its `deserialization_function` argument
+            parameter of any types which is the object to be serialized. The function should return
+            a `bytes` or `bytearray` object, which represents the serialized object. Note that the object will be
+            immediately serialized using this function, thus other serialization methods will not be used
+            (e.g. `pandas.DataFrame.to_csv`), even if possible. To deserialize this artifact when getting
+            it using the `Artifact.get` method, use its `deserialization_function` argument.
 
         :return: The status of the upload.
 
@@ -2703,7 +2706,7 @@ class Task(_Task):
             project_name = task_data.get('project_name') or Task._get_project_name(task_data.get('project', ''))
             target_task = Task.create(project_name=project_name, task_name=task_data.get('name', None))
         elif isinstance(target_task, six.string_types):
-            target_task = Task.get_task(task_id=target_task)
+            target_task = Task.get_task(task_id=target_task)  # type: Optional[Task]
         elif not isinstance(target_task, Task):
             raise ValueError(
                 "`target_task` must be either Task id (str) or Task object, "
@@ -4276,14 +4279,3 @@ class Task(_Task):
             auto_connect_frameworks={'detect_repository': False}) \
             if state['main'] else Task.get_task(task_id=state['id'])
         self.__dict__ = task.__dict__
-
-
-class _TaskStub(object):
-    def __call__(self, *args, **kwargs):
-        return self
-
-    def __getattr__(self, attr):
-        return self
-
-    def __setattr__(self, attr, val):
-        pass

clearml/utilities/proxy_object.py

@@ -80,6 +80,17 @@ class ProxyDictPreWrite(dict):
         return self._set_callback((prefix + '.' + key_value[0], key_value[1],))
 
 
+class StubObject(object):
+    def __call__(self, *args, **kwargs):
+        return self
+
+    def __getattr__(self, attr):
+        return self
+
+    def __setattr__(self, attr, val):
+        pass
+
+
 def verify_basic_type(a_dict_list, basic_types=None):
     basic_types = (float, int, bool, six.string_types, ) if not basic_types else \
         tuple(b for b in basic_types if b not in (list, tuple, dict))