diff --git a/pubtools/pulplib/_impl/client/client.py b/pubtools/pulplib/_impl/client/client.py index 253bdca0..213c19a4 100644 --- a/pubtools/pulplib/_impl/client/client.py +++ b/pubtools/pulplib/_impl/client/client.py @@ -147,7 +147,9 @@ def __init__(self, url, **kwargs): # - checks HTTP response and raises if it's not JSON or # it's not successful self._request_executor = ( - Executors.thread_pool(max_workers=self._REQUEST_THREADS) + Executors.thread_pool( + name="pubtools-pulplib-requests", max_workers=self._REQUEST_THREADS + ) .with_map(self._unpack_response) .with_retry(retry_policy=self._RETRY_POLICY) ) @@ -161,7 +163,9 @@ def __init__(self, url, **kwargs): # - throttles number of tasks pending poller = TaskPoller(self._new_session(), self._url) self._task_executor = ( - Executors.thread_pool(max_workers=self._REQUEST_THREADS) + Executors.thread_pool( + name="pubtools-pulplib-tasks", max_workers=self._REQUEST_THREADS + ) .with_map(self._unpack_response) .with_map(self._log_spawned_tasks) .with_poll(poller, cancel_fn=poller.cancel) diff --git a/requirements.txt b/requirements.txt index 3cfb5b09..4ce11cf2 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,5 +1,5 @@ requests -more-executors>=2.3.0 +more-executors>=2.7.0 six PyYAML jsonschema