From 097bf23481892725d41eba546cd9624f1a17a7ce Mon Sep 17 00:00:00 2001
From: allegroai <>
Date: Sat, 15 Jan 2022 23:03:20 +0200
Subject: [PATCH] PEP8

---
 clearml/automation/trigger.py               | 2 +-
 clearml/backend_api/session/request.py      | 4 ++--
 clearml/backend_api/session/session.py      | 1 -
 clearml/backend_interface/metrics/events.py | 1 -
 clearml/backend_interface/task/log.py       | 2 +-
 clearml/utilities/process/mp.py             | 6 ++++--
 6 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/clearml/automation/trigger.py b/clearml/automation/trigger.py
index 3b01bff8..83f1e89b 100644
--- a/clearml/automation/trigger.py
+++ b/clearml/automation/trigger.py
@@ -98,7 +98,7 @@ class DatasetTrigger(BaseTrigger):
         if self.on_archive:
             system_tags = list(set(query.get('system_tags', []) + ['archived']))
             query.update({'system_tags': system_tags})
-            
+
         return query
 
 
diff --git a/clearml/backend_api/session/request.py b/clearml/backend_api/session/request.py
index 2d84d00d..2f354137 100644
--- a/clearml/backend_api/session/request.py
+++ b/clearml/backend_api/session/request.py
@@ -1,7 +1,6 @@
 import abc
 
 import jsonschema
-import os
 import six
 
 from .apimodel import ApiModel
@@ -14,9 +13,10 @@ if ENV_API_DEFAULT_REQ_METHOD.exists() and ENV_API_DEFAULT_REQ_METHOD.get().uppe
         "CLEARML_API_DEFAULT_REQ_METHOD environment variable must be 'get' or 'post' (any case is allowed)."
     )
 
+
 class Request(ApiModel):
     _method = ENV_API_DEFAULT_REQ_METHOD.get(default="get")
-    
+
     def __init__(self, **kwargs):
         allow_extra_fields = kwargs.pop("_allow_extra_fields_", False)
         if not allow_extra_fields and kwargs:
diff --git a/clearml/backend_api/session/session.py b/clearml/backend_api/session/session.py
index 5a69dba4..745c4127 100644
--- a/clearml/backend_api/session/session.py
+++ b/clearml/backend_api/session/session.py
@@ -1,5 +1,4 @@
 import json as json_lib
-import os
 import sys
 import types
 from socket import gethostname
diff --git a/clearml/backend_interface/metrics/events.py b/clearml/backend_interface/metrics/events.py
index 947c4db5..31ce33eb 100644
--- a/clearml/backend_interface/metrics/events.py
+++ b/clearml/backend_interface/metrics/events.py
@@ -1,6 +1,5 @@
 import abc
 import hashlib
-import os
 import time
 from functools import reduce
 from logging import getLevelName
diff --git a/clearml/backend_interface/task/log.py b/clearml/backend_interface/task/log.py
index 7f9a28c9..182f0cac 100644
--- a/clearml/backend_interface/task/log.py
+++ b/clearml/backend_interface/task/log.py
@@ -82,7 +82,7 @@ class BackgroundLogService(BackgroundMonitor):
 
     def add_to_queue(self, record):
         # check that we did not loose the reporter sub-process
-        if self.is_subprocess_mode() and not self._fast_is_subprocess_alive() and not self.get_at_exit_state():  ##HANGS IF RACE HOLDS!
+        if self.is_subprocess_mode() and not self._fast_is_subprocess_alive() and not self.get_at_exit_state():  # HANGS IF RACE HOLDS!
             # we lost the reporting subprocess, let's switch to thread mode
             # gel all data, work on local queue:
             self.send_all_records()
diff --git a/clearml/utilities/process/mp.py b/clearml/utilities/process/mp.py
index 0e3c4d9c..000a0c34 100644
--- a/clearml/utilities/process/mp.py
+++ b/clearml/utilities/process/mp.py
@@ -692,8 +692,10 @@ class BackgroundMonitor(object):
         if self.get_at_exit_state():
             return self.is_subprocess_alive() and self._thread
 
-        return self.is_subprocess_alive() and self._thread and \
-               self._start_ev.is_set() and not self._done_ev.is_set()
+        return self.is_subprocess_alive() and \
+            self._thread and \
+            self._start_ev.is_set() and \
+            not self._done_ev.is_set()
 
     @classmethod
     def _fast_is_subprocess_alive(cls):