All files / services/scheduler-service/src/temporal workflows.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
const { proxyActivities } = require('@temporalio/workflow');
 
const { executeScheduledCrawl } = proxyActivities({
  startToCloseTimeout: '5 minutes',
  retry: {
    initialInterval: '10s',
    maximumAttempts: 3,
  },
});
 
async function CrawlerScheduleWorkflow(args) {
  const { scheduleId } = args;
  console.log(`[SchedulerWorkflow] Triggered for schedule ${scheduleId}`);
  await executeScheduledCrawl(scheduleId);
}
 
module.exports = { CrawlerScheduleWorkflow };