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
mssql-source: remove LEGACY state flag #33481
mssql-source: remove LEGACY state flag #33481
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
Before Merging a Connector Pull RequestWow! What a great pull request you have here! 🎉 To merge this PR, ensure the following has been done/considered for each connector added or updated:
If the checklist is complete, but the CI check is failing,
|
…e-legacy-state-mssql-source
protected boolean supportsPerStream() { | ||
return true; | ||
} | ||
protected void dropSchemas() {} |
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.
remove
# Conflicts: # airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties # airbyte-cdk/java/airbyte-cdk/db-sources/src/test/java/io/airbyte/cdk/integrations/source/relationaldb/AbstractDbSourceTest.java
…e-legacy-state-mssql-source
@@ -147,7 +144,8 @@ protected void setup() { | |||
testdb.getPassword(), | |||
testdb.getDatabaseDriver().getDriverClassName(), | |||
testdb.getJdbcUrl(), | |||
Map.of("encrypt", "false")); | |||
Map.of("encrypt", "false"), | |||
CONNECTION_TIME); |
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.
you can also pass JdbcConnector.CONNECT_DEFAULT_TIMEOUT. But this is just fine too
@@ -25,7 +28,8 @@ protected void testCreatingDataSourceWithConnectionTimeoutSetBelowDefault() { | |||
container.getPassword(), | |||
container.getDriverClassName(), | |||
container.getJdbcUrl(), | |||
connectionProperties); | |||
connectionProperties, | |||
CONNECTION_TIMEOUT); |
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.
I'm surprised the test passes with this change. I expect you'd need to pass new MsSqlSource.getConnectionTimeout(connectionProperties)
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.
I'm surprised the tests are passing. If they're causing you issues, I commented on what's the right value to pass
# Conflicts: # airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties
Issue : #33290
Based on PR #33434