Skip to content

Commit

Permalink
fix: register the correct activities for each worker
Browse files Browse the repository at this point in the history
  • Loading branch information
aubin-tchoi committed Nov 21, 2024
1 parent 11ca2b3 commit cd1d988
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions connectors/src/connectors/zendesk/temporal/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,14 @@ import logger from "@connectors/logger/logger";

import * as activities from "./activities";
import { GARBAGE_COLLECT_QUEUE_NAME, QUEUE_NAME } from "./config";
import * as gc_activities from "./gc_activities";
import * as incremental_activities from "./incremental_activities";

export async function runZendeskWorkers() {
const { connection, namespace } = await getTemporalWorkerConnection();
const syncWorker = await Worker.create({
workflowsPath: require.resolve("./workflows"),
activities,
activities: { ...activities, ...incremental_activities },
taskQueue: QUEUE_NAME,
connection,
reuseV8Context: true,
Expand All @@ -39,7 +41,7 @@ export async function runZendeskWorkers() {

const gcWorker = await Worker.create({
workflowsPath: require.resolve("./workflows"),
activities,
activities: { ...activities, ...gc_activities },
taskQueue: GARBAGE_COLLECT_QUEUE_NAME,
connection,
reuseV8Context: true,
Expand Down

0 comments on commit cd1d988

Please sign in to comment.