simplify delegated operation doc

fiftyone/factory/repos/delegated_operation.py

@@ -214,6 +214,7 @@ def queue_operation(self, **kwargs: Any) -> DelegatedOperationDocument:
             context.request_params["dataset_id"] = str(op.dataset_id)
             context.request_params["dataset_name"] = context.dataset.name
 
+        op.context = context
         doc = self._collection.insert_one(op.to_pymongo())
         op.id = doc.inserted_id
         return DelegatedOperationDocument().from_pymongo(op.__dict__)

fiftyone/factory/repos/delegated_operation_doc.py

@@ -24,17 +24,14 @@ def __init__(
         self,
         operator: str = None,
         delegation_target: str = None,
-        context: dict = None,
+        context: ExecutionContext = None,
         is_remote: bool = False,
     ):
         self.operator = operator
         self.label = None
         self.delegation_target = delegation_target
-        self.context = (
-            context.to_dict()
-            if isinstance(context, ExecutionContext)
-            else context
-        )
+        assert isinstance(context, ExecutionContext) or context is None
+        self.context = context
         self.run_state = (
             ExecutionRunState.SCHEDULED
             if is_remote
@@ -111,11 +108,10 @@ def from_pymongo(self, doc: dict):
 
     def to_pymongo(self) -> dict:
         d = self.__dict__
-        d["context"] = (
-            d["context"].to_dict()
-            if isinstance(d["context"], ExecutionContext)
-            else d["context"]
-        )
+        if self.context:
+            d["context"] = {
+                "request_params": self.context._get_serialized_request_params()
+            }
         d.pop("_doc")
         d.pop("id")
         return d

fiftyone/operators/executor.py

@@ -889,6 +889,11 @@ def store(self, store_name):
         dataset_id = self.dataset._doc.id
         return ExecutionStore.create(store_name, dataset_id)
 
+    def _get_serialized_request_params(self):
+        request_params_copy = self.request_params.copy()
+        request_params_copy.pop("panel_state", None)
+        return request_params_copy
+
     def serialize(self):
         """Serializes the execution context.