lourenco/mgmt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lang: Rename the vertex names

Browse Source 
Make it a bit more obvious what the generated nodes are for.
This commit is contained in:
James Shubin
2025-07-07 21:13:55 -04:00
parent 737d1c9004
commit 984aa0f5fc
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lang/core/iter/filter.go
View File

@@ -314,7 +314,7 @@ func (obj *FilterFunc) replaceSubGraph(subgraphInput interfaces.Func) error {
// "filterCombineList0" -> "outputListFunc" // "filterCombineList0" -> "outputListFunc"
// "filterCombineList1" -> "outputListFunc" // "filterCombineList1" -> "outputListFunc"
// "filterCombineList2" -> "outputListFunc" // "filterCombineList2" -> "outputListFunc"
// "outputListFunc" -> "subgraphOutput" // "outputListFunc" -> "filterSubgraphOutput"
// } // }
const channelBasedSinkFuncArgNameEdgeName = structs.ChannelBasedSinkFuncArgName // XXX: not sure if the specific name matters. const channelBasedSinkFuncArgNameEdgeName = structs.ChannelBasedSinkFuncArgName // XXX: not sure if the specific name matters.
@@ -333,7 +333,7 @@ func (obj *FilterFunc) replaceSubGraph(subgraphInput interfaces.Func) error {
// create the new subgraph // create the new subgraph
obj.outputChan = make(chan types.Value) obj.outputChan = make(chan types.Value)
subgraphOutput := &structs.ChannelBasedSinkFunc{ subgraphOutput := &structs.ChannelBasedSinkFunc{
Name: "subgraphOutput", Name: "filterSubgraphOutput",
Target: obj, Target: obj,
EdgeName: channelBasedSinkFuncArgNameEdgeName, EdgeName: channelBasedSinkFuncArgNameEdgeName,
Chan: obj.outputChan, Chan: obj.outputChan,

4
lang/core/iter/map.go
View File

@@ -363,7 +363,7 @@ func (obj *MapFunc) replaceSubGraph(subgraphInput interfaces.Func) error {
// "outputElem1" -> "outputListFunc" // "outputElem1" -> "outputListFunc"
// "outputElem2" -> "outputListFunc" // "outputElem2" -> "outputListFunc"
// //
// "outputListFunc" -> "subgraphOutput" // "outputListFunc" -> "mapSubgraphOutput"
// } // }
const channelBasedSinkFuncArgNameEdgeName = structs.ChannelBasedSinkFuncArgName // XXX: not sure if the specific name matters. const channelBasedSinkFuncArgNameEdgeName = structs.ChannelBasedSinkFuncArgName // XXX: not sure if the specific name matters.
@@ -377,7 +377,7 @@ func (obj *MapFunc) replaceSubGraph(subgraphInput interfaces.Func) error {
obj.outputChan = make(chan types.Value) obj.outputChan = make(chan types.Value)
subgraphOutput := &structs.ChannelBasedSinkFunc{ subgraphOutput := &structs.ChannelBasedSinkFunc{
Name: "subgraphOutput", Name: "mapSubgraphOutput",
Target: obj, Target: obj,
EdgeName: channelBasedSinkFuncArgNameEdgeName, EdgeName: channelBasedSinkFuncArgNameEdgeName,
Chan: obj.outputChan, Chan: obj.outputChan,

4
lang/funcs/structs/call.go
View File

@@ -212,7 +212,7 @@ func (obj *CallFunc) replaceSubGraph(newFuncValue *full.FuncValue) error {
// ArgVertices[1] -> ... // ArgVertices[1] -> ...
// ArgVertices[2] -> ... // ArgVertices[2] -> ...
// //
// outputFunc -> "subgraphOutput" // outputFunc -> "callSubgraphOutput"
// } // }
// delete the old subgraph // delete the old subgraph
@@ -233,7 +233,7 @@ func (obj *CallFunc) replaceSubGraph(newFuncValue *full.FuncValue) error {
obj.outputChan = make(chan types.Value) obj.outputChan = make(chan types.Value)
edgeName := ChannelBasedSinkFuncArgName edgeName := ChannelBasedSinkFuncArgName
subgraphOutput := &ChannelBasedSinkFunc{ subgraphOutput := &ChannelBasedSinkFunc{
Name: "subgraphOutput", Name: "callSubgraphOutput",
Target: obj, Target: obj,
EdgeName: edgeName, EdgeName: edgeName,
Chan: obj.outputChan, Chan: obj.outputChan,