Function findRun

packages/cluster/test/ClusterWorkflowEngine.test.ts:324–330

(entityType: string)

      yield* Fiber.join(fiber)

      const findRun = (entityType: string) =>
        driver.journal.find(
          (envelope) =>
            envelope._tag === "Request" &&
            envelope.address.entityType === entityType &&
            envelope.tag === "run"
        )
      const parentRun = findRun("Workflow/DiscardParentWorkflow")
      const childRun = findRun("Workflow/DiscardChildWorkflow")
      assert.exists(parentRun, "expected a run envelope for the parent workflow")