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
Destinations: Refreshes: CDK updates #38067
base: edgao/bigquery_more_cdk_bump
Are you sure you want to change the base?
Destinations: Refreshes: CDK updates #38067
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
9f8ae69
to
50c1e4b
Compare
50c1e4b
to
e857ce6
Compare
Warning This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
This stack of pull requests is managed by Graphite. Learn more about stacking. |
DestinationSyncMode.APPEND_DEDUP, | ||
primaryKey, | ||
Optional.of(cursor), | ||
COLUMNS | ||
COLUMNS, | ||
0, |
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.
maybe we should use nonzero generation id, so that tests are slightly more stringent?
DestinationSyncMode.OVERWRITE, | ||
mock(), | ||
mock(), | ||
mock() | ||
mock(), | ||
0, |
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.
for a later stacked PR: I think we need to add generation-related logic into DefaultTyperDeduper? so we'll want more test cases in this class...
e857ce6
to
982948e
Compare
import java.util.* | ||
import kotlin.collections.LinkedHashMap | ||
|
||
data class StreamConfig( | ||
val id: StreamId, | ||
val syncMode: SyncMode, |
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.
this is the source sync mode, which we should never look at. Delete it.
6839b3f
to
d361d45
Compare
a3bb96c
to
eca8010
Compare
7aff2a5
to
2047aec
Compare
eca8010
to
7058132
Compare
2047aec
to
2f4b6ac
Compare
7058132
to
1306644
Compare
29b9eb8
to
50418fc
Compare
6f4584b
to
9613270
Compare
50418fc
to
96c05b1
Compare
9613270
to
a906976
Compare
96c05b1
to
8660758
Compare
a906976
to
02bb59f
Compare
8660758
to
0ba6c7b
Compare
stream.syncId = 0 | ||
// TODO set platform version | ||
throw ConfigErrorException( | ||
"You must upgrade your platform version to use this connector version. Either downgrade your connector or upgrade platform to X.Y.Z" |
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.
NIT: put an actual version?
02bb59f
to
45e05ef
Compare
0ba6c7b
to
3b692fc
Compare
45e05ef
to
d8c7059
Compare
3b692fc
to
066e07c
Compare
d8c7059
to
6a53eca
Compare
066e07c
to
79e5222
Compare
6a53eca
to
78a6637
Compare
79e5222
to
8136e82
Compare
78a6637
to
6a9a958
Compare
8136e82
to
25730e1
Compare
6a9a958
to
6388cd2
Compare
25730e1
to
1767d43
Compare
6388cd2
to
0da8739
Compare
1767d43
to
80eff9f
Compare
0da8739
to
e03f5fa
Compare
80eff9f
to
e2e12d8
Compare
closes https://github.com/airbytehq/airbyte-internal-issues/issues/7606
These are the changes that break platform compatibility. We shouldn't release this until platform is ready for it, and we can turn on the
supportsRefreshes
metadata in destinations.