- All working locally.

Author: general-kroll-4-life

internal/stackql/dependencyplanner/dependencyplanner.go

@@ -677,8 +677,8 @@ func (dp *standardDependencyPlanner) getStreamFromEdge(
 	staticParams := make(map[string]interface{})
 	for k, v := range params {
 		existingSourceParam, isExistingFromSource := dp.extractStaticSourceParam(e, k)
-		// isVector := dp.isVectorParam(v)
-		if _, ok := incomingCols[k]; !ok {
+		isVector := dp.isVectorParam(v)
+		if _, ok := incomingCols[k]; !ok && !isVector {
 			staticParams[k] = v
 			incomingCols[k] = struct{}{}
 		} else if isExistingFromSource && false {

internal/stackql/drm/drm_cfg.go

@@ -558,7 +558,7 @@ func (dc *staticDRMConfig) GenerateInsertDML(
 	}
 	priorParameters := tabAnnotated.GetParameters()
 	// TODO: fix this for dependent table where dependency has `IN` clause!!!
-	transformedParams, paramErr := util.TransformSQLRawParameters(priorParameters, false)
+	transformedParams, paramErr := util.TransformSQLRawParameters(priorParameters, true)
 	if paramErr != nil {
 		return nil, paramErr
 	}