This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch aevri/picklable_jobs in repository https://gitbox.apache.org/repos/asf/buildstream.git
commit 95a4d579605c8664137b28480f0949f4dff37d5c Author: Angelos Evripiotis <[email protected]> AuthorDate: Wed Apr 10 13:08:20 2019 +0100 WIP: pickle: queues no longer pickled --- src/buildstream/_scheduler/queues/artifactpushqueue.py | 6 ------ src/buildstream/_scheduler/queues/buildqueue.py | 6 ------ src/buildstream/_scheduler/queues/fetchqueue.py | 6 ------ 3 files changed, 18 deletions(-) diff --git a/src/buildstream/_scheduler/queues/artifactpushqueue.py b/src/buildstream/_scheduler/queues/artifactpushqueue.py index dc6300e..0b6fa13 100644 --- a/src/buildstream/_scheduler/queues/artifactpushqueue.py +++ b/src/buildstream/_scheduler/queues/artifactpushqueue.py @@ -32,12 +32,6 @@ class ArtifactPushQueue(Queue): complete_name = "Pushed" resources = [ResourceType.UPLOAD] - def __getstate__(self): - import copy - state = copy.copy(self.__dict__) - del state['_scheduler'] - return state - def get_process_func(self): return _raise_skip_if_not_pushed diff --git a/src/buildstream/_scheduler/queues/buildqueue.py b/src/buildstream/_scheduler/queues/buildqueue.py index 5336416..faecc45 100644 --- a/src/buildstream/_scheduler/queues/buildqueue.py +++ b/src/buildstream/_scheduler/queues/buildqueue.py @@ -34,12 +34,6 @@ class BuildQueue(Queue): complete_name = "Built" resources = [ResourceType.PROCESS, ResourceType.CACHE] - def __getstate__(self): - import copy - state = copy.copy(self.__dict__) - del state['_scheduler'] - return state - def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self._tried = set() diff --git a/src/buildstream/_scheduler/queues/fetchqueue.py b/src/buildstream/_scheduler/queues/fetchqueue.py index 7ee962f..790ea3e 100644 --- a/src/buildstream/_scheduler/queues/fetchqueue.py +++ b/src/buildstream/_scheduler/queues/fetchqueue.py @@ -35,12 +35,6 @@ class FetchQueue(Queue): complete_name = "Fetched" resources = [ResourceType.DOWNLOAD] - def __getstate__(self): - import copy - state = copy.copy(self.__dict__) - del state['_scheduler'] - return state - def __init__(self, scheduler, skip_cached=False, fetch_original=False): super().__init__(scheduler)
