Merge pull request #90 from MinaFoundation/feature/ocv-vote-async-wor…

…ker-adjust-filter feat: only include proposals whose funding round is currently in cosi…
MinaFoundation · Dec 19, 2024 · 11dc467 · 11dc467
2 parents 6ea1e0d + 8005368
commit 11dc467
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/src/scripts/bree-runner.ts b/src/scripts/bree-runner.ts
@@ -17,8 +17,8 @@ const bree = new Bree({
   errorHandler: (error, workerMetadata) => {
     logger.error(`[Bree Runner] Worker ${workerMetadata.name} encountered an error:`, error);
   },
-  workerMessageHandler: (name, message) => {
-    logger.error(`[Bree Runner] Message from worker ${name}`);
+  workerMessageHandler: (message, workerMetadata) => {
+    // empty intentionally
   }
 });
 

diff --git a/src/tasks/ocv-vote-counting.ts b/src/tasks/ocv-vote-counting.ts
@@ -164,11 +164,17 @@ async function processProposals() {
       PROCESS_PROPOSALS_HEARTBEAT_INTERVAL
     );
 
-    // Get active proposals
+    // Get set of active proposals. An active proposal is one whose funding round currently in consideratoin dates, and the proposal's status is either CONSIDERATION or DELIBERATION
     const activeProposals = await prisma.proposal.findMany({
       where: {
         status: {
           in: [ProposalStatus.CONSIDERATION, ProposalStatus.DELIBERATION]
+        },
+        fundingRound: {
+          considerationPhase: {
+            startDate: { lte: new Date() },
+            endDate: { gte: new Date() }
+          }
         }
       },
       include: {