ClearML/clearml
1
0
Fork 0
mirror of https://github.com/clearml/clearml synced 2025-03-03 10:42:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix python 3.10 support

Browse Source
This commit is contained in:
allegroai 2022-03-11 23:52:11 +02:00
parent 4c666b1829
commit fcdc561f5f
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
clearml/backend_interface/task/development/worker.py
View File

@ -54,10 +54,10 @@ class DevWorker(object):
last_ping = time() last_ping = time()
while self._task is not None: while self._task is not None:
try: 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 return
# send ping request # 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() self.ping()
last_ping = time() last_ping = time()
if self._dev_stop_signal: if self._dev_stop_signal:

2
clearml/backend_interface/task/log.py
View File

@ -210,7 +210,7 @@ class TaskHandler(BufferingHandler):
self._offline_log_filename = offline_folder / self.__offline_filename self._offline_log_filename = offline_folder / self.__offline_filename
self._background_log = BackgroundLogService( self._background_log = BackgroundLogService(
worker=task.session.worker, task=task, 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) offline_log_filename=self._offline_log_filename)
self._background_log_size = 0 self._background_log_size = 0
if use_subprocess: if use_subprocess:

2
clearml/task.py
View File

@ -2875,7 +2875,7 @@ class Task(_Task):
self._reporter.async_enable = True self._reporter.async_enable = True
# if we just created the logger, set default flush period # if we just created the logger, set default flush period
if not flush_period or flush_period is self.NotSet: 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)): if isinstance(flush_period, (int, float)):
flush_period = int(abs(flush_period)) flush_period = int(abs(flush_period))