Added .coveragerc to exclude some lines

.coveragerc

@@ -0,0 +1,5 @@
+[report]
+exclude_lines =
+    pragma: no cover
+    raise NotImplementedError
+    if __name__ == .__main__.:

golem/core/fileencrypt.py

@@ -8,15 +8,6 @@
 from io import IOBase
 
 
-class abstractclassmethod(classmethod):
-
-    __isabstractmethod__ = True
-
-    def __init__(self, func):
-        func.__isabstractmethod__ = True
-        super(abstractclassmethod, self).__init__(func)
-
-
 class FileHelper(object):
 
     def __init__(self, param, mode):
@@ -46,13 +37,15 @@ def gen_secret(cls, min_length, max_length):
             n_chars = cls.__strong_random.randrange(min_length, max_length)
             return Random.new().read(n_chars)
 
-    @abstractclassmethod
+    @classmethod
+    @abc.abstractmethod
     def encrypt(cls, file_in, file_out, key_or_secret):
-        pass
+        raise NotImplementedError
 
-    @abstractclassmethod
+    @classmethod
+    @abc.abstractmethod
     def decrypt(cls, file_in, file_out, key_or_secret):
-        pass
+        raise NotImplementedError
 
 
 class AESFileEncryptor(FileEncryptor):

golem/core/service.py

@@ -14,15 +14,15 @@ class IService(ABC):
 
     @abstractmethod
     def start(self) -> None:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def stop(self) -> None:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def running(self) -> bool:
-        pass
+        raise NotImplementedError
 
 
 class LoopingCallService(IService):

golem/diag/service.py

@@ -21,7 +21,7 @@ class DiagnosticsOutputFormat(object):
 class DiagnosticsProvider(object, metaclass=abc.ABCMeta):
     @abc.abstractmethod
     def get_diagnostics(self, output_format):
-        pass
+        raise NotImplementedError
 
     @staticmethod
     def _format_diagnostics(data, output_format):

golem/docker/environment.py

@@ -66,22 +66,22 @@ def get_container_config(self) -> Dict:
     @property
     @abc.abstractmethod
     def DOCKER_IMAGE(cls):
-        pass
+        raise NotImplementedError
 
     @property
     @abc.abstractmethod
     def DOCKER_TAG(cls):
-        pass
+        raise NotImplementedError
 
     @property
     @abc.abstractmethod
     def ENV_ID(cls):
-        pass
+        raise NotImplementedError
 
     @property
     @abc.abstractmethod
     def SHORT_DESCRIPTION(cls):
-        pass
+        raise NotImplementedError
 
     @classmethod
     def get_id(cls):

golem/envs/__init__.py

@@ -3,7 +3,6 @@
 from enum import Enum
 from logging import Logger, getLogger
 from threading import RLock
-from pathlib import Path
 
 from typing import Any, Callable, Dict, List, Optional, NamedTuple, Union, \
     Sequence, Iterable, ContextManager, Set, Tuple
@@ -123,6 +122,7 @@ def close(self):
             a closed input won't do anything.
             NOTE: If there are many open input handles for a single Runtime
             then closing one of them will effectively close all the other. """
+        raise NotImplementedError
 
     def __enter__(self) -> 'RuntimeInput':
         return self

golem/interface/formatters.py

@@ -22,7 +22,7 @@ def clear_argument(self, arg_dict):
 
     @abc.abstractmethod
     def format(self, result):
-        pass
+        raise NotImplementedError
 
     @staticmethod
     def _initial_format(result):

golem/monitor/model/modelbase.py

@@ -7,7 +7,7 @@ class ModelBase(object, metaclass=abc.ABCMeta):
     @abc.abstractmethod
     def dict_repr(self):
         """Returns dictionary representation of the current instance"""
-        pass
+        raise NotImplementedError
 
 
 class BasicModel(ModelBase):

golem/network/transport/network.py

@@ -7,15 +7,15 @@
 class Network(abc.ABC):
     @abc.abstractmethod
     def connect(self, connect_info: TCPConnectInfo) -> None:
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def listen(self, listen_info: TCPListenInfo) -> None:
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def stop_listening(self, listening_info: TCPListeningInfo):
-        return
+        raise NotImplementedError
 
 
 class SessionFactory(object):
@@ -115,19 +115,17 @@ class Session(object, metaclass=abc.ABCMeta):
     CONN_TYPE_CLIENT = 1
     CONN_TYPE_SERVER = 2
 
-    @abc.abstractmethod
-    def __init__(self, conn):
+    def __init__(self):
         self.conn_type = None
-        return
 
     @abc.abstractmethod
     def dropped(self):
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def interpret(self, msg):
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def disconnect(self, reason):
-        return
+        raise NotImplementedError

golem/network/transport/session.py

@@ -19,15 +19,15 @@ class FileSession(Session, metaclass=abc.ABCMeta):
 
     @abc.abstractmethod
     def data_sent(self, extra_data=None):
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def full_data_received(self, extra_data=None):
-        return
+        raise NotImplementedError
 
     @abc.abstractmethod
     def production_failed(self, extra_data=None):
-        return
+        raise NotImplementedError
 
 
 class BasicSession(FileSession):
@@ -41,7 +41,7 @@ def __init__(self, conn):
         :param Protocol conn: connection protocol implementation that
                               this session should enhance.
         """
-        Session.__init__(self, conn)
+        Session.__init__(self)
         self.conn = conn
 
         pp = conn.transport.getPeer()

golem/network/upnp/mapper.py

@@ -15,37 +15,37 @@ class IPortMapper(ABC):
     @property
     @abstractmethod
     def available(self) -> bool:
-        pass
+        raise NotImplementedError
 
     @property
     @abstractmethod
     def network(self) -> dict:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def discover(self) -> str:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def get_mapping(self,
                     external_port: int,
                     protocol: str = 'TCP') -> Optional[Tuple[str, int, bool]]:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def create_mapping(self,
                        local_port: int,
                        external_port: int = None,
                        protocol: str = 'TCP',
                        lease_duration: int = None) -> Optional[int]:
-        pass
+        raise NotImplementedError
 
     @abstractmethod
     def remove_mapping(self,
                        port: int,
                        external_port: int,
                        protocol: str = 'TCP') -> bool:
-        pass
+        raise NotImplementedError
 
 
 class PortMapperManager(IPortMapper):

golem/task/acl.py

@@ -24,12 +24,12 @@ class DenyReason(Enum):
 class Acl(abc.ABC):
     @abc.abstractmethod
     def is_allowed(self, node_id: str) -> Tuple[bool, Optional[DenyReason]]:
-        pass
+        raise NotImplementedError
 
     @abc.abstractmethod
     def disallow(self, node_id: str, timeout_seconds: int, persist: bool) \
             -> None:
-        pass
+        raise NotImplementedError
 
 
 class _DenyAcl(Acl):

golem/task/appcallbacks/appcallbacks.py

@@ -18,7 +18,7 @@ def create_payload(
             command: str,
             port: int,
     ) -> RuntimePayload:
-        raise NotImplementedError()
+        raise NotImplementedError
 
 
 class EnvironmentCallbacks(AppCallbacks):

golem/task/result/resultmanager.py

@@ -18,11 +18,11 @@ def __init__(self, resource_manager):
 
     @abc.abstractmethod
     def create(self, node, task_result, **kwargs):
-        pass
+        raise NotImplementedError
 
     @abc.abstractmethod
     def extract(self, path, output_dir=None, **kwargs):
-        pass
+        raise NotImplementedError
 
 
 class EncryptedResultPackageManager(TaskResultPackageManager):

golem/task/result/resultpackage.py

@@ -72,19 +72,19 @@ def _prepare_file_dict(cls, disk_files) -> Dict[str, str]:
 
     @abc.abstractmethod
     def extract(self, input_path, output_dir=None):
-        pass
+        raise NotImplementedError
 
     @abc.abstractmethod
     def generator(self, output_path):
-        pass
+        raise NotImplementedError
 
     @abc.abstractmethod
     def package_name(self, file_path):
-        pass
+        raise NotImplementedError
 
     @abc.abstractmethod
     def write_disk_file(self, package_file, src_path, target_path):
-        pass
+        raise NotImplementedError
 
 
 class ZipPackager(Packager):