- fix xpush to job level

maycuatroi · Jul 2, 2023 · 5d5fe33 · 5d5fe33
1 parent e844f22
commit 5d5fe33
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/evoflow/operators/base_operator.py b/evoflow/operators/base_operator.py
@@ -28,7 +28,7 @@ def __repr__(self):
         return f"{self.__class__.__name__} {self.task_id}"
 
     def xcom_push(self, key, value):
-        self.params[key] = value
+        self.job.params_pool[key] = value
 
     def xcom_pull(self, key, **kwargs):
-        return self.params[key]
+        return self.job.params_pool[key]