ClearML/clearml-agent
1
0
Fork 0
mirror of https://github.com/clearml/clearml-agent synced 2025-02-12 07:38:04 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove unused code

Browse Source
This commit is contained in:
allegroai 2022-10-23 12:58:49 +03:00
parent 3f7a4840cc
commit 70771b12a9
1 changed files with 2 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
clearml_agent/commands/worker.py
View File

@ -20,14 +20,12 @@ from datetime import datetime
from distutils.spawn import find_executable from distutils.spawn import find_executable
from distutils.util import strtobool from distutils.util import strtobool
from functools import partial from functools import partial
from itertools import chain
from os.path import basename from os.path import basename
from tempfile import mkdtemp, NamedTemporaryFile from tempfile import mkdtemp, NamedTemporaryFile
from time import sleep, time from time import sleep, time
from typing import Text, Optional, Any, Tuple, List from typing import Text, Optional, Any, Tuple, List
import attr import attr
import psutil
import six import six
from pathlib2 import Path from pathlib2 import Path
from six.moves.urllib.parse import quote from six.moves.urllib.parse import quote
@ -636,21 +634,12 @@ class Worker(ServiceCommandSection):
self._pip_extra_index_url.insert(0, e) self._pip_extra_index_url.insert(0, e)
except Exception: except Exception:
self.log.warning('Failed adding extra-index-url to pip environment: {}'.format(extra_url)) self.log.warning('Failed adding extra-index-url to pip environment: {}'.format(extra_url))
# update pip install command
pip_install_cmd = ["pip", "install"]
if self._pip_extra_index_url:
pip_install_cmd.extend(
chain.from_iterable(
("--extra-index-url", x) for x in self._pip_extra_index_url
)
)
self.pip_install_cmd = tuple(pip_install_cmd)
self.worker_id = self._session.config["agent.worker_id"] or "{}:{}".format( self.worker_id = self._session.config["agent.worker_id"] or "{}:{}".format(
self._session.config["agent.worker_name"], os.getpid() self._session.config["agent.worker_name"], os.getpid()
) )
self.parent_worker_id = None # maybe add os env for overriding self.parent_worker_id = None # maybe add os env for overriding
self._last_stats = defaultdict(lambda: 0)
self._last_report_timestamp = psutil.time.time()
self.temp_config_path = None self.temp_config_path = None
self.queues = () self.queues = ()
self.venv_folder = None # type: Optional[Text] self.venv_folder = None # type: Optional[Text]