| 54 | } |
| 55 | |
| 56 | func BuildWithBuilder(rctx *runtime.Context, main *dag.Main, env *exec.Environment, readers []sio.Reader) (map[string]vio.Puller, *op.DebugChans, *rungen.Builder, error) { |
| 57 | b := rungen.NewBuilder(rctx, env) |
| 58 | outputs, debugs, err := b.Build(main, readers...) |
| 59 | if err != nil { |
| 60 | return nil, nil, nil, err |
| 61 | } |
| 62 | return outputs, debugs, b, nil |
| 63 | } |
| 64 | |
| 65 | func CompileWithAST(rctx *runtime.Context, ast *parser.AST, env *exec.Environment, optimize bool, parallel int, readers []sio.Reader) (*exec.Query, error) { |
| 66 | main, err := Analyze(rctx, ast, env, len(readers) > 0) |