Skip to content

Commit

Permalink
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/batch/dump-db-to-kafka.ts
Original file line number Diff line number Diff line change
@@ -9,7 +9,7 @@ import createProducer from '../kafka/automatisk-reaktivert-producer';
const automatiskReaktivering = await prismaClient.automatiskReaktivering.findMany({
where: {
created_at: {
lt: new Date(),
lt: new Date('2023-02-27 12:22:53.584000 UTC'),
},
},
});
@@ -22,13 +22,13 @@ import createProducer from '../kafka/automatisk-reaktivert-producer';
const automatiskReaktiveringSvar = await prismaClient.automatiskReaktiveringSvar.findMany({
where: {
created_at: {
lt: new Date(),
lt: new Date('2023-02-27 12:26:09.939000 UTC'),
},
},
});

console.log(`Fant ${automatiskReaktiveringSvar.length} rader`);
console.log('Dumper automatiskReaktiveringSvar på kafka...');
await kafkaProducer.send(automatiskReaktiveringSvar);
console.log('Ferdig med automatiskReaktiveringSvar');
console.log('Ferdig med automatiskReaktiveringSvar\n\n');
})();

0 comments on commit 23c3140

Please sign in to comment.