Function TestReparse

runtime/parser/parser_test.go:457–599

(t *testing.T)

}

func TestReparse(t *testing.T) {
	// Prepare
	ctx := context.Background()

	// Create empty project
	repo := makeRepo(t, map[string]string{`rill.yaml`: ``})
	p, err := Parse(ctx, repo, "", "", "duckdb", true)
	require.NoError(t, err)
	requireResourcesAndErrors(t, p, nil, nil)

	// Add a source
	putRepo(t, repo, map[string]string{
		`sources/s1.yaml`: `
connector: s3
path: hello
`,
	})
	s1 := &Resource{
		Name:  ResourceName{Kind: ResourceKindModel, Name: "s1"},
		Paths: []string{"/sources/s1.yaml"},
		ModelSpec: &runtimev1.ModelSpec{
			InputConnector:   "s3",
			OutputConnector:  "duckdb",
			InputProperties:  must(structpb.NewStruct(map[string]any{"path": "hello"})),
			OutputProperties: must(structpb.NewStruct(map[string]any{"materialize": true})),
			RefreshSchedule:  &runtimev1.Schedule{RefUpdate: true},
			DefinedAsSource:  true,
			ChangeMode:       runtimev1.ModelChangeMode_MODEL_CHANGE_MODE_RESET,
		},
	}
	diff, err := p.Reparse(ctx, s1.Paths)
	require.NoError(t, err)
	requireResourcesAndErrors(t, p, []*Resource{s1}, nil)
	require.Equal(t, &Diff{
		Added: []ResourceName{s1.Name},
	}, diff)

	// Add a model
	putRepo(t, repo, map[string]string{
		`models/m1.sql`: `
SELECT * FROM foo
`,
	})
	m1 := &Resource{
		Name:  ResourceName{Kind: ResourceKindModel, Name: "m1"},
		Paths: []string{"/models/m1.sql"},
		ModelSpec: &runtimev1.ModelSpec{
			RefreshSchedule: &runtimev1.Schedule{RefUpdate: true},
			InputConnector:  "duckdb",
			InputProperties: must(structpb.NewStruct(map[string]any{"sql": "SELECT * FROM foo"})),
			OutputConnector: "duckdb",
			ChangeMode:      runtimev1.ModelChangeMode_MODEL_CHANGE_MODE_RESET,
		},
	}
	diff, err = p.Reparse(ctx, m1.Paths)
	require.NoError(t, err)
	requireResourcesAndErrors(t, p, []*Resource{s1, m1}, nil)
	require.Equal(t, &Diff{