Make PrimitiveJob serializable

qiskit/primitives/containers/data_bin.py

@@ -93,9 +93,6 @@ def __init__(self, *, shape: ShapeInput = (), **data):
     def __len__(self):
         return len(self._data)
 
-    def __setattr__(self, *_):
-        raise NotImplementedError
-
     def __repr__(self):
         vals = [f"{name}={_value_repr(val)}" for name, val in self.items()]
         if self.ndim:

qiskit/primitives/primitive_job.py

@@ -27,14 +27,16 @@ class PrimitiveJob(BasePrimitiveJob[ResultT, JobStatus]):
     Primitive job class for the reference implementations of Primitives.
     """
 
-    def __init__(self, function, *args, **kwargs):
+    def __init__(self, function=None, *args, **kwargs):
         """
         Args:
             function: A callable function to execute the job.
         """
         super().__init__(str(uuid.uuid4()))
         self._future = None
         self._function = function
+        self._result = None
+        self._status = None
         self._args = args
         self._kwargs = kwargs
 
@@ -46,19 +48,30 @@ def _submit(self):
         self._future = executor.submit(self._function, *self._args, **self._kwargs)
         executor.shutdown(wait=False)
 
+    def _prepare_dump(self):
+        _ = self.result()
+        _ = self.status()
+        self._future = None
+
     def result(self) -> ResultT:
-        self._check_submitted()
-        return self._future.result()
+        if self._result is None:
+            self._check_submitted()
+            self._result = self._future.result()
+        return self._result
 
     def status(self) -> JobStatus:
-        self._check_submitted()
-        if self._future.running():
-            return JobStatus.RUNNING
-        elif self._future.cancelled():
-            return JobStatus.CANCELLED
-        elif self._future.done() and self._future.exception() is None:
-            return JobStatus.DONE
-        return JobStatus.ERROR
+        if self._status is None:
+            self._check_submitted()
+            if self._future.running():
+                # we should not store status running because it is not completed
+                return JobStatus.RUNNING
+            elif self._future.cancelled():
+                self._status = JobStatus.CANCELLED
+            elif self._future.done() and self._future.exception() is None:
+                self._status = JobStatus.DONE
+            else:
+                self._status = JobStatus.ERROR
+        return self._status
 
     def _check_submitted(self):
         if self._future is None: