De-noise removal of unprocessed envelopes
Co-authored-by: trevor-signal <131492920+trevor-signal@users.noreply.github.com>
This commit is contained in:
parent
3d777371eb
commit
ae3ade4c13
1 changed files with 0 additions and 2 deletions
|
@ -4601,7 +4601,6 @@ function getUnprocessedByIdsAndIncrementAttempts(
|
|||
}
|
||||
|
||||
function removeUnprocesseds(db: WritableDB, ids: ReadonlyArray<string>): void {
|
||||
logger.info('removeUnprocesseds', { totalIds: ids.length });
|
||||
db.prepare<ArrayQuery>(
|
||||
`
|
||||
DELETE FROM unprocessed
|
||||
|
@ -4611,7 +4610,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…
Add table
Reference in a new issue