Function makeWorkflowEntity

packages/cluster/src/ClusterWorkflowEngine.ts:610–632

(workflow: Workflow.Any)

const payloadParentKey = "~@effect/workflow/parent" as const

const makeWorkflowEntity = (workflow: Workflow.Any) =>
  Entity.make(`Workflow/${workflow.name}`, [
    Rpc.make("run", {
      payload: {
        ...workflow.payloadSchema.fields,
        [payloadParentKey]: Schema.optional(Schema.Struct({
          workflowName: Schema.String,
          executionId: Schema.String
        }))
      },
      primaryKey: () => "",
      success: Workflow.Result({
        success: workflow.successSchema,
        error: workflow.errorSchema
      })
    })
      .annotate(ClusterSchema.Persisted, true)
      .annotate(ClusterSchema.Uninterruptible, true),

    DeferredRpc,
    ResumeRpc,
    ActivityRpc
  ]).annotateContext(workflow.annotations)

const ExitUnknown = Schema.Exit({
  success: Schema.Unknown,