Commit 73c08e55 authored by harshit aggarwal's avatar harshit aggarwal
Browse files

Adding more descriptive logs

parent 524a1d46
Pipeline #25147 passed with stages
in 24 minutes and 39 seconds
...@@ -6,7 +6,7 @@ ...@@ -6,7 +6,7 @@
global: global:
# Service(s) Replica Count # Service(s) Replica Count
replicaCount: 1 replicaCount: 16
azure: azure:
servicebusSubscription: eg_sb_wkssubscription servicebusSubscription: eg_sb_wkssubscription
......
...@@ -113,4 +113,4 @@ spec: ...@@ -113,4 +113,4 @@ spec:
- name: executor_n_threads - name: executor_n_threads
value: "64" value: "64"
- name: max_lock_renew_duration_seconds - name: max_lock_renew_duration_seconds
value: "1000" value: "2000"
\ No newline at end of file \ No newline at end of file
...@@ -211,7 +211,15 @@ public class WKSServiceImpl implements WKSService { ...@@ -211,7 +211,15 @@ public class WKSServiceImpl implements WKSService {
} }
try { try {
LOGGER.info("Querying storage in a batch of size {} for Raw records with ids {}", batch.length, ids);
Records records = storageService.getRecordBatch(ids); Records records = storageService.getRecordBatch(ids);
if(records.getRecords().size() == ids.size()) {
LOGGER.info("Successfully fetched all {} raw records from storage", records.getRecords().size());
}
else {
LOGGER.info("Unable to fetch {} raw records with ids {}", records.getNotFound().size(), records.getNotFound());
}
for (Records.Entity rawRecord : records.getRecords()) { for (Records.Entity rawRecord : records.getRecords()) {
rawRecords.put(rawRecord.getId(), convertJsonStringToTree(this.gson.toJson(rawRecord))); rawRecords.put(rawRecord.getId(), convertJsonStringToTree(this.gson.toJson(rawRecord)));
} }
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment