Function enqueueCohortCompute

packages/db/src/services/cohort.service.ts:602–612

(cohortId: string)

}

export async function enqueueCohortCompute(cohortId: string): Promise<void> {
  await cohortComputeQueue.add(
    'cohortCompute',
    { cohortId },
    {
      jobId: `cohort-${cohortId}`,
      removeOnComplete: { age: 3600 },
      removeOnFail: { age: 86400 },
    },
  );
}

export async function removeCohortComputeJob(cohortId: string): Promise<void> {
  await cohortComputeQueue.remove(