Skip to content

Commit

Permalink
temporarily commented dp graph
Browse files Browse the repository at this point in the history
  • Loading branch information
avneesh-akto committed Mar 7, 2024
1 parent 04a9dad commit b313db2
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -172,9 +172,9 @@ public void syncFunction(List<HttpResponseParams> responseParams, boolean syncIm
apiCatalogSync.computeDelta(aggregator, false, apiCollectionId);
}

for (HttpResponseParams responseParam: filteredResponseParams) {
dependencyAnalyser.analyse(responseParam.getOrig(), responseParam.requestParams.getApiCollectionId());
}
// for (HttpResponseParams responseParam: filteredResponseParams) {
// dependencyAnalyser.analyse(responseParam.getOrig(), responseParam.requestParams.getApiCollectionId());
// }

this.sync_count += filteredResponseParams.size();
int syncThresh = numberOfSyncs < 10 ? 10000 : sync_threshold_count;
Expand Down
6 changes: 3 additions & 3 deletions apps/dashboard/src/main/java/com/akto/utils/Utils.java
Original file line number Diff line number Diff line change
Expand Up @@ -476,9 +476,9 @@ public static void pushDataToKafka(int apiCollectionId, String topic, List<Strin
info.getHttpCallParser().apiCatalogSync.buildFromDB(false, false);
APICatalogSync.updateApiCollectionCount(info.getHttpCallParser().apiCatalogSync.getDbState(apiCollectionId), apiCollectionId);
try {
DependencyFlow dependencyFlow = new DependencyFlow();
dependencyFlow.run();
dependencyFlow.syncWithDb();
// DependencyFlow dependencyFlow = new DependencyFlow();
// dependencyFlow.run();
// dependencyFlow.syncWithDb();
} catch (Exception e) {
loggerMaker.errorAndAddToDb(e,"Exception while running dependency flow", LoggerMaker.LogDb.DASHBOARD);
}
Expand Down

0 comments on commit b313db2

Please sign in to comment.