diff --git a/lib/cron/fade-rate-v2.ts b/lib/cron/fade-rate-v2.ts index dd84b93..a8f15ba 100644 --- a/lib/cron/fade-rate-v2.ts +++ b/lib/cron/fade-rate-v2.ts @@ -150,14 +150,11 @@ export function getFillersNewFades( (fillerTimestamps.has(fillerHash) && row.postTimestamp > fillerTimestamps.get(fillerHash)!.lastPostTimestamp) || !fillerTimestamps.has(fillerHash) ) { - log?.info({ row: row }, 'new fade'); if (!newFadesMap[fillerHash]) { newFadesMap[fillerHash] = row.faded; } else { newFadesMap[fillerHash] += row.faded; } - } else { - log?.info({ row: row }, 'no new fade'); } }); log?.info({ newFadesMap }, '# of new fades by filler'); diff --git a/lib/repositories/fades-repository.ts b/lib/repositories/fades-repository.ts index ddaa083..040bfcf 100644 --- a/lib/repositories/fades-repository.ts +++ b/lib/repositories/fades-repository.ts @@ -100,7 +100,7 @@ export class V2FadesRepository extends BaseRedshiftRepository { const formattedRow: V2FadesRowType = { // the ordering of the fields has to match that in the sql query fillerAddress: row[0].stringValue as string, - postTimestamp: Number(row[1].longValue as number), + postTimestamp: parseInt(row[1].stringValue as string), faded: Number(row[2].longValue as number), }; return formattedRow;