|
1 | 1 | package uk.gov.hmcts.cp.cdk.jobmanager.caseflow; |
2 | 2 |
|
3 | | -import static uk.gov.hmcts.cp.cdk.jobmanager.TaskNames.CHECK_INGESTION_STATUS_FOR_DOCUMENT; |
4 | | -import static uk.gov.hmcts.cp.cdk.jobmanager.TaskNames.GENERATE_ANSWER_FOR_QUERY; |
5 | | -import static uk.gov.hmcts.cp.cdk.jobmanager.support.JobManagerKeys.CTX_SINGLE_QUERY_ID; |
6 | | -import static uk.gov.hmcts.cp.cdk.util.TimeUtils.utcNow; |
7 | | -import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INGESTION_FAILED; |
8 | | -import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INGESTION_SUCCESS; |
9 | | -import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INVALID_METADATA; |
10 | | - |
| 3 | +import jakarta.json.Json; |
| 4 | +import jakarta.json.JsonObject; |
| 5 | +import lombok.RequiredArgsConstructor; |
| 6 | +import lombok.extern.slf4j.Slf4j; |
| 7 | +import org.jetbrains.annotations.NotNull; |
| 8 | +import org.springframework.http.ResponseEntity; |
| 9 | +import org.springframework.stereotype.Component; |
11 | 10 | import uk.gov.hmcts.cp.cdk.batch.support.QueryResolver; |
12 | 11 | import uk.gov.hmcts.cp.cdk.domain.DocumentIngestionPhase; |
13 | 12 | import uk.gov.hmcts.cp.cdk.domain.Query; |
|
30 | 29 | import java.util.stream.Collectors; |
31 | 30 | import java.util.stream.IntStream; |
32 | 31 |
|
33 | | -import jakarta.json.Json; |
34 | | -import jakarta.json.JsonObject; |
35 | | -import lombok.RequiredArgsConstructor; |
36 | | -import org.jetbrains.annotations.NotNull; |
37 | | -import org.slf4j.Logger; |
38 | | -import org.slf4j.LoggerFactory; |
39 | | -import org.springframework.http.ResponseEntity; |
40 | | -import org.springframework.stereotype.Component; |
| 32 | +import static uk.gov.hmcts.cp.cdk.jobmanager.TaskNames.CHECK_INGESTION_STATUS_FOR_DOCUMENT; |
| 33 | +import static uk.gov.hmcts.cp.cdk.jobmanager.TaskNames.GENERATE_ANSWER_FOR_QUERY; |
| 34 | +import static uk.gov.hmcts.cp.cdk.jobmanager.support.JobManagerKeys.CTX_SINGLE_QUERY_ID; |
| 35 | +import static uk.gov.hmcts.cp.cdk.util.TimeUtils.utcNow; |
| 36 | +import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INGESTION_FAILED; |
| 37 | +import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INGESTION_SUCCESS; |
| 38 | +import static uk.gov.hmcts.cp.openapi.model.DocumentIngestionStatus.INVALID_METADATA; |
41 | 39 |
|
42 | 40 | @Component |
43 | 41 | @RequiredArgsConstructor |
44 | 42 | @Task(CHECK_INGESTION_STATUS_FOR_DOCUMENT) |
| 43 | +@Slf4j |
45 | 44 | public class CheckIngestionStatusForDocumentTask implements ExecutableTask { |
46 | 45 |
|
47 | | - private static final Logger log = LoggerFactory.getLogger(CheckIngestionStatusForDocumentTask.class); |
48 | 46 | private final DocumentIngestionStatusApi documentIngestionStatusApi; |
49 | 47 | private final CaseDocumentRepository caseDocumentRepository; |
50 | 48 | private final QueryResolver queryResolver; |
@@ -72,7 +70,7 @@ public ExecutionInfo execute(final ExecutionInfo executionInfo) { |
72 | 70 | final UUID documentId = parseUuid(jobData.getString("docId", null)); |
73 | 71 | final UUID caseId = parseUuid(jobData.getString("caseId", null)); |
74 | 72 | final String blobName = jobData.getString("blobName", null); |
75 | | - final Set<String> FAILURE_STATUSES = Set.of( |
| 73 | + final Set<String> failureStatuses = Set.of( |
76 | 74 | INGESTION_FAILED.name(), |
77 | 75 | INVALID_METADATA.name() |
78 | 76 | ); |
@@ -143,7 +141,7 @@ public ExecutionInfo execute(final ExecutionInfo executionInfo) { |
143 | 141 | } |
144 | 142 |
|
145 | 143 | return complete(executionInfo); |
146 | | - } else if (FAILURE_STATUSES.contains(status.toUpperCase())) { |
| 144 | + } else if (failureStatuses.contains(status.toUpperCase())) { |
147 | 145 |
|
148 | 146 | updateIngestionPhase(documentId, DocumentIngestionPhase.FAILED); |
149 | 147 | log.error( |
|
0 commit comments