@@ -610,19 +610,6 @@ func (dp *standardDependencyPlanner) isVectorParam(param interface{}) bool {
610610 return false
611611}
612612
613- func (dp * standardDependencyPlanner ) extractStaticSourceParam (e dataflow.Edge , paramKey string ) (interface {}, bool ) {
614- if e .GetSource () == nil || e .
615- GetSource ().GetAnnotation () == nil || e .
616- GetSource ().GetAnnotation ().GetParameters () == nil {
617- return nil , false
618- }
619- v , ok := e .GetSource ().GetAnnotation ().GetParameters ()[paramKey ]
620- if ! ok {
621- return nil , false
622- }
623- return dp .getScalarParam (v )
624- }
625-
626613//nolint:gocognit,nestif // live with it
627614func (dp * standardDependencyPlanner ) getStreamFromEdge (
628615 e dataflow.Edge ,
@@ -676,13 +663,10 @@ func (dp *standardDependencyPlanner) getStreamFromEdge(
676663 params := toAc .GetParameters ()
677664 staticParams := make (map [string ]interface {})
678665 for k , v := range params {
679- existingSourceParam , isExistingFromSource := dp .extractStaticSourceParam (e , k )
680666 isVector := dp .isVectorParam (v )
681667 if _ , ok := incomingCols [k ]; ! ok && ! isVector {
682668 staticParams [k ] = v
683669 incomingCols [k ] = struct {}{}
684- } else if isExistingFromSource && false {
685- staticParams [k ] = existingSourceParam
686670 }
687671 }
688672 if len (staticParams ) > 0 {
0 commit comments