diff --git a/packages/node_modules/@node-red/runtime/lib/flows/Flow.js b/packages/node_modules/@node-red/runtime/lib/flows/Flow.js
index 02b976a32..f96a67780 100644
--- a/packages/node_modules/@node-red/runtime/lib/flows/Flow.js
+++ b/packages/node_modules/@node-red/runtime/lib/flows/Flow.js
@@ -699,6 +699,13 @@ class Flow {
             let toSend = msg;
             this.completeNodeMap[node.id].forEach((completeNode,index) => {
                 toSend = redUtil.cloneMessage(msg);
+                toSend.complete = {
+                    source: {
+                        id: node.id,
+                        type: node.type,
+                        name: node.name
+                    }
+                };
                 completeNode.receive(toSend);
             })
         }