-
Notifications
You must be signed in to change notification settings - Fork 4.4k
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
Force legacy if feature flag not set #14694
Conversation
/test connector=connectors/source-postgres
|
if (!featureFlags.useStreamCapableState()) { | ||
return List.of(new AirbyteStateMessage() | ||
.withType(AirbyteStateType.LEGACY) | ||
.withData(Jsons.emptyObject())); | ||
} |
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.
@benmoriceau it looks like the non-overriden method does .withData(Jsons.jsonNode(new DbState()))
, but here you are using .withData(Jsons.emptyObject())
:
Line 551 in 7bff12a
return List.of(new AirbyteStateMessage().withType(AirbyteStateType.LEGACY).withData(Jsons.jsonNode(new DbState()))); |
Should these be the same?
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 think so. I have updated it
4cdb0b5
to
4975382
Compare
/test connector=connectors/source-postgres
|
assertTrue(streamsInStateAfterFirstSyncCompletion.contains(new StreamDescriptor().withName(MODELS_STREAM_NAME).withNamespace(MODELS_SCHEMA)));*/ | ||
assertNotNull(stateMessageEmittedAfterFirstSyncCompletion.getData()); | ||
assertTrue(streamsInStateAfterFirstSyncCompletion.contains(new StreamDescriptor().withName(MODELS_STREAM_NAME).withNamespace(MODELS_SCHEMA))); | ||
assertNotNull(stateMessageEmittedAfterFirstSyncCompletion.getData());*/ |
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.
included this line in the commented out code, because we are doing the same assert on line 411
/test connector=connectors/source-postgres
Build FailedTest summary info:
|
/test connector=connectors/source-postgres
Build FailedTest summary info:
|
I have created a separate commit #14703 to disable the test |
/test connector=connectors/source-postgres
Build PassedTest summary info:
|
/publish connector=connectors/source-postgres
if you have connectors that successfully published but failed definition generation, follow step 4 here |
/publish connector=connectors/source-postgres-strict-encrypt if you have connectors that successfully published but failed definition generation, follow step 4 here |
What
for the legacy mode for if the feature flag is not set to true.
Issue : https://github.com/airbytehq/oncall/issues/339