-
Notifications
You must be signed in to change notification settings - Fork 125
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
model executor for postgres and mysql to duckdb #6083
base: main
Are you sure you want to change the base?
Conversation
f1e6c60
to
fb1b3e1
Compare
@@ -123,3 +132,55 @@ func allMySQLDataTypesTest(t *testing.T, db *sql.DB, dsn string) { | |||
require.NoError(t, res.Close()) | |||
require.NoError(t, to.Close()) | |||
} | |||
|
|||
func mysqlToDuckDB(t *testing.T, dsn string) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we move this test to a test file that starts with model_executor_
instead? For when we drop the transporter
files?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Actually I planned to rename this file and drop the transporter test when re drop the transporter files. Till then kept it in the same file to avoid creating more test containers and keep test time short.
I am okay to also create new test if you prefer that way.
@@ -86,3 +93,80 @@ func allDataTypesTest(t *testing.T, db *sql.DB, dbURL string) { | |||
require.NoError(t, res.Close()) | |||
require.NoError(t, to.Close()) | |||
} | |||
|
|||
func pgxToDuckDB(t *testing.T, pgdb *sql.DB, dbURL string) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Similar comment about moving to a model executor related test file
subtask for https://github.com/rilldata/rill-private-issues/issues/854
Sample model yaml that ingests from postgres.