WIP: pickle: queues no longer pickled

3 files changed, 0 insertions, 18 deletions

diff --git a/src/buildstream/_scheduler/queues/artifactpushqueue.py b/src/buildstream/_scheduler/queues/artifactpushqueue.py
index dc6300ee2..0b6fa1301 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 53364166d..faecc4502 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 7ee962f6e..790ea3eee 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)