Fix implicit any types on transaction callback parameters
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com> Signed-off-by: Fredrik Adelöw <freben@gmail.com>
This commit is contained in:
@@ -229,7 +229,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
|
||||
// single transaction so that the row locks persist until
|
||||
// next_update_at has been bumped.
|
||||
const run = async (tx: Knex | Knex.Transaction) => {
|
||||
const items = await tx<DbRefreshStateRow>('refresh_state')
|
||||
const items: DbRefreshStateRow[] = await tx('refresh_state')
|
||||
.select([
|
||||
'entity_id',
|
||||
'entity_ref',
|
||||
@@ -250,7 +250,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
|
||||
});
|
||||
|
||||
if (items.length > 0) {
|
||||
await tx<DbRefreshStateRow>('refresh_state')
|
||||
await tx('refresh_state')
|
||||
.whereIn(
|
||||
'entity_ref',
|
||||
items.map(i => i.entity_ref),
|
||||
|
||||
+2
-2
@@ -61,7 +61,7 @@ export async function getDeferredStitchableEntities(options: {
|
||||
// are released after the SELECT auto-commits, and another worker can
|
||||
// claim the same rows before the UPDATE runs.
|
||||
const run = async (tx: Knex | Knex.Transaction) => {
|
||||
const items = await tx<DbStitchQueueRow>('stitch_queue')
|
||||
const items: DbStitchQueueRow[] = await tx('stitch_queue')
|
||||
.select('entity_ref', 'next_stitch_at', 'stitch_ticket')
|
||||
.where('next_stitch_at', '<=', tx.fn.now())
|
||||
.orderBy('next_stitch_at', 'asc')
|
||||
@@ -76,7 +76,7 @@ export async function getDeferredStitchableEntities(options: {
|
||||
return [];
|
||||
}
|
||||
|
||||
await tx<DbStitchQueueRow>('stitch_queue')
|
||||
await tx('stitch_queue')
|
||||
.whereIn(
|
||||
'entity_ref',
|
||||
items.map(i => i.entity_ref),
|
||||
|
||||
Reference in New Issue
Block a user