Don't update message args when adding meta args before calling pipeline

Flared · Feb 14, 2024 · 2ff4e7c · 2ff4e7c
1 parent bb6dcd0
commit 2ff4e7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/saturn_engine/worker/pipeline_message.py b/src/saturn_engine/worker/pipeline_message.py
@@ -47,7 +47,7 @@ def set_meta_arg(self, *, meta_type: t.Type, value: t.Any) -> None:
     def execute(self) -> object:
         pipeline = self.info.into_pipeline()
         pipeline_args_def = dataclass_from_params(pipeline)
-        args = self.message.args
+        args = dict(self.message.args)
 
         for meta_name, value in self.meta_args.items():
             meta_type = import_name(meta_name)