refactor: modify job handling in PendingImportScannerTask to continue on missing S3 files
This commit is contained in:
parent
8052c391bf
commit
533e7ce21a
@ -32,7 +32,7 @@ public class PendingImportScannerTask {
|
|||||||
|
|
||||||
for (var job : pendingJobs) {
|
for (var job : pendingJobs) {
|
||||||
if (!s3Service.objectExists(job.getS3FileKey())) {
|
if (!s3Service.objectExists(job.getS3FileKey())) {
|
||||||
return;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
log.info("Found file for job {} in S3: {}", job.getId(), job.getS3FileKey());
|
log.info("Found file for job {} in S3: {}", job.getId(), job.getS3FileKey());
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user