From fcdc561f5f053312aee9a81b6c8e0561819ed86b Mon Sep 17 00:00:00 2001
From: allegroai <>
Date: Fri, 11 Mar 2022 23:52:11 +0200
Subject: [PATCH] Fix python 3.10 support

---
 clearml/backend_interface/task/development/worker.py | 4 ++--
 clearml/backend_interface/task/log.py                | 2 +-
 clearml/task.py                                      | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/clearml/backend_interface/task/development/worker.py b/clearml/backend_interface/task/development/worker.py
index b253a567..63efcdc3 100644
--- a/clearml/backend_interface/task/development/worker.py
+++ b/clearml/backend_interface/task/development/worker.py
@@ -54,10 +54,10 @@ class DevWorker(object):
         last_ping = time()
         while self._task is not None:
             try:
-                if self._exit_event.wait(min(self.ping_period, self.report_period)):
+                if self._exit_event.wait(min(float(self.ping_period), float(self.report_period))):
                     return
                 # send ping request
-                if self._support_ping and (time() - last_ping) >= self.ping_period:
+                if self._support_ping and (time() - last_ping) >= float(self.ping_period):
                     self.ping()
                     last_ping = time()
                 if self._dev_stop_signal:
diff --git a/clearml/backend_interface/task/log.py b/clearml/backend_interface/task/log.py
index 182f0cac..fa28c255 100644
--- a/clearml/backend_interface/task/log.py
+++ b/clearml/backend_interface/task/log.py
@@ -210,7 +210,7 @@ class TaskHandler(BufferingHandler):
             self._offline_log_filename = offline_folder / self.__offline_filename
         self._background_log = BackgroundLogService(
             worker=task.session.worker, task=task,
-            session=task.session, wait_period=DevWorker.report_period,
+            session=task.session, wait_period=float(DevWorker.report_period),
             offline_log_filename=self._offline_log_filename)
         self._background_log_size = 0
         if use_subprocess:
diff --git a/clearml/task.py b/clearml/task.py
index 14adb97f..699e6f02 100644
--- a/clearml/task.py
+++ b/clearml/task.py
@@ -2875,7 +2875,7 @@ class Task(_Task):
             self._reporter.async_enable = True
             # if we just created the logger, set default flush period
             if not flush_period or flush_period is self.NotSet:
-                flush_period = DevWorker.report_period
+                flush_period = float(DevWorker.report_period)
 
         if isinstance(flush_period, (int, float)):
             flush_period = int(abs(flush_period))