in src/main/java/com/google/gcs/sdrs/service/worker/rule/impl/StsRuleValidator.java [137:173]
RetentionJobValidation convertOperationToJobValidation(Operation operation, int jobId) {
RetentionJobValidation validation = new RetentionJobValidation();
validation.setJobOperationName(operation.getName());
validation.setRetentionJobId(jobId);
if (!operation.getDone()) {
validation.setStatus(RetentionJobStatusType.PENDING);
} else if (operation.getResponse() != null) {
if (operation.getMetadata().get("status").equals("SUCCESS")) {
validation.setStatus(RetentionJobStatusType.SUCCESS);
} else {
validation.setStatus(RetentionJobStatusType.ERROR);
}
validation.setStartTime(getJobTime(operation, true));
validation.setEndTime(getJobTime(operation, false));
validation.setMetadata(operation.getMetadata().toString());
String operationPrettyString = null;
try {
operationPrettyString = operation.toPrettyString();
} catch (IOException e) {
operationPrettyString = operation.getMetadata().toString();
}
logger.info(
String.format(
"STS Operation %s Successful: %s", operation.getName(), operationPrettyString));
} else {
validation.setStatus(RetentionJobStatusType.ERROR);
logger.error(
String.format(
"STS Operation %s failed: %s",
operation.getName(), operation.getError().getMessage()));
}
return validation;
}