FIX store_output_as fails if the node copy the message

mhcomm · Oct 10, 2023 · f7e8536 · f7e8536
1 parent 283e64f
commit f7e8536
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pypeman/nodes.py b/pypeman/nodes.py
@@ -190,7 +190,7 @@ async def handle(self, msg):
                     # TODO Here result is last value returned. Is it a good idea ?
             else:
                 if self.store_output_as:
-                    msg.add_context(self.store_output_as, msg)
+                    result.add_context(self.store_output_as, result)
 
                 if self.passthrough:
                     result.payload = old_msg.payload