|
@@ -335,6 +335,7 @@ async function processFile(entry, filePath) {
|
|
|
try {
|
|
try {
|
|
|
return await processFileOnce(entry, filePath)
|
|
return await processFileOnce(entry, filePath)
|
|
|
} catch (err) {
|
|
} catch (err) {
|
|
|
|
|
+ if (gracefulShutdownInitiated) throw err
|
|
|
if (err instanceof NotFoundError) {
|
|
if (err instanceof NotFoundError) {
|
|
|
const { bucketName } = OError.getFullInfo(err)
|
|
const { bucketName } = OError.getFullInfo(err)
|
|
|
if (bucketName === USER_FILES_BUCKET_NAME && !RETRY_FILESTORE_404) {
|
|
if (bucketName === USER_FILES_BUCKET_NAME && !RETRY_FILESTORE_404) {
|
|
@@ -991,6 +992,7 @@ class ProjectContext {
|
|
|
try {
|
|
try {
|
|
|
return await backupPersistor.forProject(projectBlobsBucket, key)
|
|
return await backupPersistor.forProject(projectBlobsBucket, key)
|
|
|
} catch (err) {
|
|
} catch (err) {
|
|
|
|
|
+ if (gracefulShutdownInitiated) throw err
|
|
|
if (err instanceof NoKEKMatchedError) {
|
|
if (err instanceof NoKEKMatchedError) {
|
|
|
throw err
|
|
throw err
|
|
|
} else {
|
|
} else {
|