add dummy workflow

Author: skwowet

services/apps/cache_worker/src/workflows.ts

@@ -1,3 +1,4 @@
+import { checkRedis } from './workflows/compute-orgs-agg/checkRedis'
 import { computeOrgAggsAndUpdate } from './workflows/compute-orgs-agg/computeOrgAggsAndUpdate'
 import { dailyGetAndComputeOrgAggs } from './workflows/compute-orgs-agg/getAndComputeOrgAggs'
 import { refreshDashboardCache } from './workflows/refreshDashboardCache'
@@ -8,4 +9,5 @@ export {
   refreshDashboardCache,
   dailyGetAndComputeOrgAggs,
   computeOrgAggsAndUpdate,
+  checkRedis,
 }

services/apps/cache_worker/src/workflows/compute-orgs-agg/checkRedis.ts

@@ -0,0 +1,19 @@
+import { proxyActivities } from '@temporalio/workflow'
+
+import * as activities from '../../activities/computeAggs/organization'
+
+const activity = proxyActivities<typeof activities>({ startToCloseTimeout: '15 minutes' })
+
+/*
+  dailyGetAndComputeOrgAggs is a Temporal workflow that:
+    - [Activity]: Get organization IDs from Redis.
+    - [Child Workflow]: Re-compute and update aggregates for each organization 
+      in batches of 50. Child workflows run independently and won't be 
+      cancelled if the parent workflow stops.
+  */
+export async function checkRedis(): Promise<void> {
+  const { cursor, organizationIds } = await activity.getOrgIdsFromRedis()
+
+  console.log('cursor', cursor)
+  console.log('organizationIds', organizationIds)
+}