Function run

apps/hash-integration-worker/src/main.ts:74–93

()

    : { kind: "path", workflowsPath: require.resolve("./workflows") };

async function run() {
  const graphApiClient = createGraphClient(logger, {
    host: getRequiredEnv("HASH_GRAPH_HTTP_HOST"),
    port: parseInt(getRequiredEnv("HASH_GRAPH_HTTP_PORT"), 10),
  });

  await runWorker({
    serviceName: "integration worker",
    taskQueue: "integration",
    healthCheckPort: 4300,
    activities: {
      ...linearActivities.createLinearIntegrationActivities({ graphApiClient }),
      ...createFlowActivities({ graphApiClient }),
      ...createCommonFlowActivities({ graphApiClient }),
    },
    workflowSource,
    otelSetup,
    logger,
  });
}

run().catch((error: unknown) => {
  logger.error("Error running worker", { error });