De-noise removal of unprocessed envelopes
This commit is contained in:
parent
abdef4847a
commit
81c8ba0b62
1 changed files with 0 additions and 2 deletions
|
@ -4599,7 +4599,6 @@ function getUnprocessedByIdsAndIncrementAttempts(
|
|||
}
|
||||
|
||||
function removeUnprocesseds(db: WritableDB, ids: ReadonlyArray<string>): void {
|
||||
logger.info('removeUnprocesseds', { totalIds: ids.length });
|
||||
db.prepare<ArrayQuery>(
|
||||
`
|
||||
DELETE FROM unprocessed
|
||||
|
@ -4609,7 +4608,6 @@ function removeUnprocesseds(db: WritableDB, ids: ReadonlyArray<string>): void {
|
|||
}
|
||||
|
||||
function removeUnprocessed(db: WritableDB, id: string | Array<string>): void {
|
||||
logger.info('removeUnprocessedSync', { id });
|
||||
if (!Array.isArray(id)) {
|
||||
prepare(db, 'DELETE FROM unprocessed WHERE id = $id;').run({ id });
|
||||
|
||||
|
|
Loading…
Reference in a new issue