in src/main/java/com/amazonaws/schemamanager/registry/SchemaRegistryClient.java [312:331]
private void updateDependency(RepoSchema repoSchema, String dependency,
Map<String, Subject> registrySubjects) {
Subject depSubj = resolvedVersions.get(dependency);
if (depSubj == null) {
if ((depSubj = registrySubjects.get(dependency)) == null) return;
}
String schemaType = repoSchema.getSchema().schemaType();
if (ProtobufSchema.TYPE.equals(schemaType)) {
List<SchemaReference> refs = repoSchema.getSchema().references();
if (refs == null || refs.isEmpty()) return;
for (SchemaReference ref : refs) {
if (ref.getName().equals(dependency)) {
ref.setVersion(depSubj.getLatestVersionId());
return;
}
}
}
}