Skip to content
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.

Sign up for GitHub

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

Use the new get out of date connectors endpoint #20155

Merged
merged 16 commits into from
Jan 3, 2023
Merged

Use the new get out of date connectors endpoint #20155

Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
c7e8579
Add /v1/web_backend/check_updates
gosusnp Dec 3, 2022
8f4b2d5
Add constant for fallback cases
gosusnp Dec 5, 2022
e2de431
Uses the new get out of date connectors endpoint
krishnaglick Dec 6, 2022
031c8a3
Move connector service to its own file. Invalidate count on version c…
krishnaglick Dec 12, 2022
1d27973
Better upgrade all functionality
krishnaglick Dec 12, 2022
a82d68e
Cleanup
krishnaglick Dec 12, 2022
c9ab8a2
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Dec 12, 2022
8c5abf3
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Dec 13, 2022
f823dc2
Merge branch 'master' of github.com:airbytehq/airbyte into kc/use-new…
krishnaglick Dec 16, 2022
0a4b78e
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Dec 16, 2022
cc74b2e
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Dec 16, 2022
ddbb843
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Dec 19, 2022
6e14ee5
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Jan 3, 2023
263def8
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Jan 3, 2023
fabc2cf
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Jan 3, 2023
bc1a02e
Merge branch 'master' into kc/use-new-out-of-date-definitions-endpoint
krishnaglick Jan 3, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Add /v1/web_backend/check_updates
  • Loading branch information
@gosusnp @krishnaglick
gosusnp authored and krishnaglick committed Dec 12, 2022
commit c7e8579810edf01a960989ef1fa357724f52a7e3
10 changes: 4 additions & 6 deletions airbyte-server/src/main/java/io/airbyte/server/handlers/WebBackendCheckUpdatesHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,6 @@
@Slf4j
public class WebBackendCheckUpdatesHandler {

private static final int NO_CHANGES_FOUND = 0;

final ConfigRepository configRepository;
final AirbyteGithubStore githubStore;

Expand All @@ -48,7 +46,7 @@ private int getDestinationDiffCount() {
.toList();
} catch (final IOException e) {
log.error("Failed to get current list of standard destination definitions", e);
return NO_CHANGES_FOUND;
return 0;
}

try {
Expand All @@ -57,7 +55,7 @@ private int getDestinationDiffCount() {
.collect(Collectors.toMap(StandardDestinationDefinition::getDestinationDefinitionId, StandardDestinationDefinition::getDockerImageTag));
} catch (final InterruptedException e) {
log.error("Failed to get latest list of standard destination definitions", e);
return NO_CHANGES_FOUND;
return 0;
}

return getDiffCount(currentActorDefToDockerImageTag, newActorDefToDockerImageTag);
Expand All @@ -74,7 +72,7 @@ private int getSourceDiffCount() {
.toList();
} catch (final IOException e) {
log.error("Failed to get current list of standard source definitions", e);
return NO_CHANGES_FOUND;
return 0;
}

try {
Expand All @@ -83,7 +81,7 @@ private int getSourceDiffCount() {
.collect(Collectors.toMap(StandardSourceDefinition::getSourceDefinitionId, StandardSourceDefinition::getDockerImageTag));
} catch (final InterruptedException e) {
log.error("Failed to get latest list of standard source definitions", e);
return NO_CHANGES_FOUND;
return 0;
}

return getDiffCount(currentActorDefToDockerImageTag, newActorDefToDockerImageTag);
Expand Down