You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@buildstream.apache.org by gi...@apache.org on 2020/12/29 13:22:17 UTC
[buildstream] 27/33: WIP: pickle: queues no longer pickled
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 <je...@bloomberg.net>
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)