Function runWorkflow

worker/scripts/workflow-runner.ts:151–177

(
  client: Client,
  definition: WorkflowDefinition,
  workflowRecordId: string,
  fileId: string,
)

}

async function runWorkflow(
  client: Client,
  definition: WorkflowDefinition,
  workflowRecordId: string,
  fileId: string,
): Promise<{ runId: string; result: unknown }> {
  const temporalWorkflowId = `shipsec-run-${randomUUID()}`;
  const taskQueue = process.env.TEMPORAL_TASK_QUEUE ?? 'shipsec-default';

  const handle = await client.workflow.start(shipsecWorkflowRun, {
    workflowId: temporalWorkflowId,
    taskQueue,
    args: [
      {
        runId: temporalWorkflowId,
        workflowId: workflowRecordId,
        definition,
        inputs: {
          input1: fileId,
        },
      },
    ],
  });

  const result = await handle.result();
  return { runId: temporalWorkflowId, result };
}

async function main() {
  const { workflowRecordId, fileId, limit, shouldRun, list } = parseArgs();