Function makePartialWorkflowEntity

packages/cluster/src/ClusterWorkflowEngine.ts:660–665

(workflowName: string)

  .annotate(ClusterSchema.Uninterruptible, true)

const makePartialWorkflowEntity = (workflowName: string) =>
  Entity.make(`Workflow/${workflowName}`, [
    DeferredRpc,
    ResumeRpc,
    ActivityRpc
  ])

const activityPrimaryKey = (activity: string, attempt: number) => `${activity}/${attempt}`