Skip to content

Commit

Permalink
RANGER-5145:Ranger plugin should skip building GDSInfos which are dis…
Browse files Browse the repository at this point in the history
…abled
  • Loading branch information
Ramesh Mani committed Feb 15, 2025
1 parent 33b80ef commit 90fb287
Showing 1 changed file with 16 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -149,6 +149,10 @@ private ServiceGdsInfo retrieveServiceGdsInfo(Long serviceId, String serviceName

private void populateDatasets(ServiceGdsInfo gdsInfo, SearchFilter filter) {
for (RangerGds.RangerDataset dataset : datasetService.searchDatasets(filter).getList()) {
if (Boolean.FALSE.equals(dataset.getIsEnabled())) {
continue;
}

ServiceGdsInfo.DatasetInfo dsInfo = new ServiceGdsInfo.DatasetInfo();

dsInfo.setId(dataset.getId());
Expand All @@ -162,6 +166,9 @@ private void populateDatasets(ServiceGdsInfo gdsInfo, SearchFilter filter) {

private void populateProjects(ServiceGdsInfo gdsInfo, SearchFilter filter) {
for (RangerGds.RangerProject project : projectService.searchProjects(filter).getList()) {
if (Boolean.FALSE.equals(project.getIsEnabled())) {
continue;
}
ServiceGdsInfo.ProjectInfo projInfo = new ServiceGdsInfo.ProjectInfo();

projInfo.setId(project.getId());
Expand All @@ -177,6 +184,10 @@ private void populateDataShares(ServiceGdsInfo gdsInfo, SearchFilter filter) {
RangerGdsVList.RangerDataShareList dataShares = dataShareService.searchDataShares(filter);

for (RangerGds.RangerDataShare dataShare : dataShares.getList()) {
if (Boolean.FALSE.equals(dataShare.getIsEnabled())) {
continue;
}

ServiceGdsInfo.DataShareInfo dshInfo = new ServiceGdsInfo.DataShareInfo();

dshInfo.setId(dataShare.getId());
Expand All @@ -192,6 +203,9 @@ private void populateDataShares(ServiceGdsInfo gdsInfo, SearchFilter filter) {

private void populateSharedResources(ServiceGdsInfo gdsInfo, SearchFilter filter) {
for (RangerGds.RangerSharedResource resource : sharedResourceService.searchSharedResources(filter).getList()) {
if (Boolean.FALSE.equals(resource.getIsEnabled())) {
continue;
}
ServiceGdsInfo.SharedResourceInfo resourceInfo = new ServiceGdsInfo.SharedResourceInfo();

resourceInfo.setId(resource.getId());
Expand All @@ -212,7 +226,7 @@ private void populateSharedResources(ServiceGdsInfo gdsInfo, SearchFilter filter

private void populateDataSharesInDataset(ServiceGdsInfo gdsInfo, SearchFilter filter) {
for (RangerGds.RangerDataShareInDataset dshInDs : dataShareInDatasetService.searchDataShareInDatasets(filter).getList()) {
if (dshInDs.getStatus() != RangerGds.GdsShareStatus.ACTIVE) {
if (dshInDs.getStatus() != RangerGds.GdsShareStatus.ACTIVE || Boolean.FALSE.equals(dshInDs.getIsEnabled())) {
continue;
}

Expand All @@ -230,7 +244,7 @@ private void populateDataSharesInDataset(ServiceGdsInfo gdsInfo, SearchFilter fi

private void populateDatasetsInProject(ServiceGdsInfo gdsInfo, SearchFilter filter) {
for (RangerGds.RangerDatasetInProject dip : datasetInProjectService.searchDatasetInProjects(filter).getList()) {
if (dip.getStatus() != RangerGds.GdsShareStatus.ACTIVE) {
if (dip.getStatus() != RangerGds.GdsShareStatus.ACTIVE || Boolean.FALSE.equals(dip.getIsEnabled())) {
continue;
}

Expand Down

0 comments on commit 90fb287

Please sign in to comment.