feat: serializable AbortController/AbortSignal

.changeset/drain-pending-queue-on-completion.md

@@ -0,0 +1,5 @@
+---
+"@workflow/core": patch
+---
+
+Drain pending queue items at workflow completion instead of only logging warnings, and implicitly dispose any never-aborted system (abort) hooks at completion so unused `AbortController` instances don't leave abandoned rows in the hooks table for the run's TTL

.changeset/fix-dom-exception-serialization.md

@@ -0,0 +1,5 @@
+---
+"@workflow/core": patch
+---
+
+Fix `DOMException` not serializing correctly

.changeset/serializable-abort-controller.md

@@ -0,0 +1,8 @@
+---
+"@workflow/core": patch
+"workflow": patch
+---
+
+Add serializable `AbortController` and `AbortSignal` support across workflow and step boundaries. Workflow code can now construct an `AbortController`, pass `signal` to steps, and call `abort()`.
+
+**Behavior change:** `AbortError` thrown from inside a step is now wrapped as `FatalError` and skips retry semantics. As a result, custom timeouts on `fetch` inside steps are no longer re-tried by default, and now need to be wrapped in `RetryableError` to preserve the old behavior.

docs/app/[lang]/docs/[[...slug]]/page.tsx

@@ -6,6 +6,7 @@ import { notFound, permanentRedirect } from 'next/navigation';
 import { rewriteCookbookUrl } from '@/lib/geistdocs/cookbook-source';
 import { AgentTraces } from '@/components/custom/agent-traces';
 import { FluidComputeCallout } from '@/components/custom/fluid-compute-callout';
+import { PreviewInstallServer } from '@/components/preview-install-server';
 import { AskAI } from '@/components/geistdocs/ask-ai';
 import { CopyPage } from '@/components/geistdocs/copy-page';
 import {
@@ -45,6 +46,12 @@ const Page = async ({ params }: PageProps<'/[lang]/docs/[[...slug]]'>) => {
     notFound();
   }
 
+  // preRelease pages are only reachable under /v5/docs/*. Block direct
+  // access via /docs/* so the v4 tree doesn't expose unreleased content.
+  if (page.data.preRelease) {
+    notFound();
+  }
+
   const markdown = await getLLMText(page);
   const MDX = page.data.body;
 
@@ -86,6 +93,7 @@ const Page = async ({ params }: PageProps<'/[lang]/docs/[[...slug]]'>) => {
             ...AccordionComponents,
             Tabs,
             Tab,
+            PreviewInstall: PreviewInstallServer,
             // No-op for world MDX files (they redirect to /worlds/[id])
             WorldTestingPerformance: WorldTestingPerformanceNoop,
           })}

docs/app/[lang]/docs/layout.tsx

@@ -1,12 +1,13 @@
 import { DocsLayout } from '@/components/geistdocs/docs-layout';
-import { getDocsTreeWithoutCookbook } from '@/lib/geistdocs/cookbook-source';
+import { getDocsTreeForVersion } from '@/lib/geistdocs/version-source';
+import { LATEST_VERSION } from '@/lib/geistdocs/versions';
 
 const Layout = async ({ children, params }: LayoutProps<'/[lang]/docs'>) => {
   const { lang } = await params;
 
   return (
     <div className="bg-background-100">
-      <DocsLayout tree={getDocsTreeWithoutCookbook(lang)}>
+      <DocsLayout tree={getDocsTreeForVersion(lang, LATEST_VERSION)}>
         {children}
       </DocsLayout>
     </div>

docs/app/[lang]/llms.mdx/[[...slug]]/route.ts

@@ -38,5 +38,8 @@ export const generateStaticParams = async ({
 }: RouteContext<'/[lang]/llms.mdx/[[...slug]]'>) => {
   const { lang } = await params;
 
-  return source.generateParams(lang);
+  // Exclude internal/preview-only pages from LLM scraping
+  return source
+    .generateParams(lang)
+    .filter((p) => !p.slug?.includes('internal'));
 };

docs/app/[lang]/sitemap.md/route.ts

@@ -16,6 +16,9 @@ export async function GET(
     const indent = '  '.repeat(depth);
 
     if ('type' in node) {
+      // Exclude internal/preview-only pages from sitemap
+      if (node.type === 'page' && node.url.includes('/internal')) return;
+      if (node.type === 'folder' && node.name === 'Internal') return;
       if (node.type === 'page') {
         mdText += `${indent}- [${node.name}](${rewriteCookbookUrl(node.url)})\n`;
       } else if (node.type === 'folder') {

docs/app/[lang]/v5/docs/[[...slug]]/page.tsx

@@ -0,0 +1,127 @@
+import { Step, Steps } from 'fumadocs-ui/components/steps';
+import { Tab, Tabs } from 'fumadocs-ui/components/tabs';
+import { createRelativeLink } from 'fumadocs-ui/mdx';
+import type { Metadata } from 'next';
+import { notFound, permanentRedirect } from 'next/navigation';
+import { AgentTraces } from '@/components/custom/agent-traces';
+import { FluidComputeCallout } from '@/components/custom/fluid-compute-callout';
+import { AskAI } from '@/components/geistdocs/ask-ai';
+import { CopyPage } from '@/components/geistdocs/copy-page';
+import {
+  DocsBody,
+  DocsDescription,
+  DocsPage,
+  DocsTitle,
+} from '@/components/geistdocs/docs-page';
+import { EditSource } from '@/components/geistdocs/edit-source';
+import { Feedback } from '@/components/geistdocs/feedback';
+import { getMDXComponents } from '@/components/geistdocs/mdx-components';
+import { MobileDocsBar } from '@/components/geistdocs/mobile-docs-bar';
+import { OpenInChat } from '@/components/geistdocs/open-in-chat';
+import { ScrollTop } from '@/components/geistdocs/scroll-top';
+import { PreviewInstallServer } from '@/components/preview-install-server';
+import * as AccordionComponents from '@/components/ui/accordion';
+import { Badge } from '@/components/ui/badge';
+import { Separator } from '@/components/ui/separator';
+import { rewriteCookbookUrl } from '@/lib/geistdocs/cookbook-source';
+import { getLLMText, getPageImage, source } from '@/lib/geistdocs/source';
+import { TSDoc } from '@/lib/tsdoc';
+
+const WorldTestingPerformanceNoop = () => null;
+
+const Page = async ({ params }: PageProps<'/[lang]/v5/docs/[[...slug]]'>) => {
+  const { slug, lang } = await params;
+
+  if (Array.isArray(slug) && slug[0] === 'cookbook') {
+    const rest = slug.slice(1).join('/');
+    const legacyPath = `/docs/cookbook${rest ? `/${rest}` : ''}`;
+    permanentRedirect(`/${lang}${rewriteCookbookUrl(legacyPath)}`);
+  }
+
+  const page = source.getPage(slug, lang);
+  if (!page) {
+    notFound();
+  }
+
+  const markdown = await getLLMText(page);
+  const MDX = page.data.body;
+
+  return (
+    <DocsPage
+      full={page.data.full}
+      tableOfContent={{
+        style: 'clerk',
+        footer: (
+          <div className="my-3 space-y-3">
+            <Separator />
+            <EditSource path={page.path} />
+            <ScrollTop />
+            <Feedback />
+            <CopyPage text={markdown} />
+            <AskAI href={page.url} />
+            <OpenInChat href={page.url} />
+          </div>
+        ),
+      }}
+      tableOfContentPopover={{ enabled: false }}
+      toc={page.data.toc}
+    >
+      <MobileDocsBar toc={page.data.toc} />
+      <DocsTitle>{page.data.title}</DocsTitle>
+      <DocsDescription>{page.data.description}</DocsDescription>
+      <DocsBody>
+        <MDX
+          components={getMDXComponents({
+            a: createRelativeLink(source, page),
+            AgentTraces,
+            FluidComputeCallout,
+            Badge,
+            TSDoc,
+            Step,
+            Steps,
+            ...AccordionComponents,
+            Tabs,
+            Tab,
+            PreviewInstall: PreviewInstallServer,
+            WorldTestingPerformance: WorldTestingPerformanceNoop,
+          })}
+        />
+      </DocsBody>
+    </DocsPage>
+  );
+};
+
+export const generateStaticParams = () =>
+  source
+    .generateParams()
+    .filter(
+      (params) => !(Array.isArray(params.slug) && params.slug[0] === 'cookbook')
+    );
+
+export const generateMetadata = async ({
+  params,
+}: PageProps<'/[lang]/v5/docs/[[...slug]]'>): Promise<Metadata> => {
+  const { slug, lang } = await params;
+  const page = source.getPage(slug, lang);
+  if (!page) notFound();
+  return {
+    title: `${page.data.title} · Pre-release`,
+    description: page.data.description,
+    openGraph: {
+      images: getPageImage(page).url,
+    },
+    // Pre-release pages are not canonical; point search engines at the
+    // latest URL (or self if this page is v5-only).
+    alternates: {
+      canonical: page.data.preRelease
+        ? `/${lang}/v5${page.url}`
+        : `/${lang}${page.url}`,
+    },
+    robots: {
+      index: false,
+      follow: true,
+    },
+  };
+};
+
+export default Page;

docs/app/[lang]/v5/docs/layout.tsx

@@ -0,0 +1,18 @@
+import { DocsLayout } from '@/components/geistdocs/docs-layout';
+import { PreReleaseBanner } from '@/components/geistdocs/pre-release-banner';
+import { getDocsTreeForVersion } from '@/lib/geistdocs/version-source';
+import { PRE_RELEASE_VERSION } from '@/lib/geistdocs/versions';
+
+const Layout = async ({ children, params }: LayoutProps<'/[lang]/v5/docs'>) => {
+  const { lang } = await params;
+  return (
+    <div className="bg-background-100">
+      <PreReleaseBanner pathname={`/${lang}/v5/docs`} />
+      <DocsLayout tree={getDocsTreeForVersion(lang, PRE_RELEASE_VERSION)}>
+        {children}
+      </DocsLayout>
+    </div>
+  );
+};
+
+export default Layout;

docs/app/robots.ts

@@ -8,6 +8,7 @@ export default function robots(): MetadataRoute.Robots {
     rules: {
       userAgent: '*',
       allow: '/',
+      disallow: ['/*/docs/internal/', '/docs/internal/'],
     },
     sitemap: `${baseUrl}/sitemap.xml`,
   };

docs/app/sitemap.ts

@@ -14,6 +14,8 @@ export default function sitemap(): MetadataRoute.Sitemap {
   const pages: MetadataRoute.Sitemap = [];
 
   for (const page of source.getPages()) {
+    // Exclude internal/preview-only pages from sitemap
+    if (page.url.includes('/internal')) continue;
     pages.push({
       changeFrequency: 'weekly' as const,
       lastModified: undefined,

docs/components/geistdocs/pre-release-banner.tsx

@@ -0,0 +1,49 @@
+import Link from 'next/link';
+import {
+  buildVersionUrl,
+  LATEST_VERSION,
+  PRE_RELEASE_VERSION,
+} from '@/lib/geistdocs/versions';
+
+interface PreReleaseBannerProps {
+  pathname: string;
+}
+
+const SparklesFilled = ({ className }: { className?: string }) => (
+  <svg
+    aria-hidden="true"
+    className={className}
+    fill="currentColor"
+    height="16"
+    viewBox="0 0 16 16"
+    width="16"
+    xmlns="http://www.w3.org/2000/svg"
+  >
+    <path d="M2.5 0.5V0H3.5V0.5C3.5 1.60457 4.39543 2.5 5.5 2.5H6V3V3.5H5.5C4.39543 3.5 3.5 4.39543 3.5 5.5V6H3H2.5V5.5C2.5 4.39543 1.60457 3.5 0.5 3.5H0V3V2.5H0.5C1.60457 2.5 2.5 1.60457 2.5 0.5Z" />
+    <path d="M14.5 4.5V5H13.5V4.5C13.5 3.94772 13.0523 3.5 12.5 3.5H12V3V2.5H12.5C13.0523 2.5 13.5 2.05228 13.5 1.5V1H14H14.5V1.5C14.5 2.05228 14.9477 2.5 15.5 2.5H16V3V3.5H15.5C14.9477 3.5 14.5 3.94772 14.5 4.5Z" />
+    <path d="M8.40706 4.92939L8.5 4H9.5L9.59294 4.92939C9.82973 7.29734 11.7027 9.17027 14.0706 9.40706L15 9.5V10.5L14.0706 10.5929C11.7027 10.8297 9.82973 12.7027 9.59294 15.0706L9.5 16H8.5L8.40706 15.0706C8.17027 12.7027 6.29734 10.8297 3.92939 10.5929L3 10.5V9.5L3.92939 9.40706C6.29734 9.17027 8.17027 7.29734 8.40706 4.92939Z" />
+  </svg>
+);
+
+export const PreReleaseBanner = ({ pathname }: PreReleaseBannerProps) => {
+  const latestHref = buildVersionUrl(pathname, LATEST_VERSION);
+  return (
+    <div className="border-b bg-blue-50 px-4 py-2 text-center text-sm dark:bg-blue-950/40">
+      <div className="mx-auto flex max-w-[1448px] flex-wrap items-center justify-center gap-x-3 gap-y-1">
+        <div className="flex items-center gap-2 text-blue-700 dark:text-blue-900">
+          <SparklesFilled className="size-4 shrink-0" />
+          <span>
+            Viewing Workflow {PRE_RELEASE_VERSION.id.replace(/^v/, '')}{' '}
+            (Pre-release) Documentation.
+          </span>
+        </div>
+        <Link
+          className="font-medium text-blue-700 underline underline-offset-4 decoration-blue-700/40 transition-colors hover:decoration-blue-700 dark:text-blue-900 dark:decoration-blue-900/40 dark:hover:decoration-blue-900"
+          href={latestHref}
+        >
+          Go to Workflow {LATEST_VERSION.id.replace(/^v/, '')} (Latest)
+        </Link>
+      </div>
+    </div>
+  );
+};

docs/components/geistdocs/sidebar.tsx

@@ -23,6 +23,7 @@ import {
 import { Badge } from '@/components/ui/badge';
 import { useSidebarContext } from '@/hooks/geistdocs/use-sidebar';
 import { SearchButton } from './search';
+import { VersionSwitcher } from './version-switcher';
 
 // Map of URL suffixes to badges shown inline next to the sidebar item name.
 const SIDEBAR_ITEM_BADGES: Array<{ suffix: string; label: string }> = [
@@ -70,6 +71,7 @@ export const Sidebar = () => {
       data-sidebar-placeholder
     >
       <div className="h-full overflow-y-auto px-4 pt-12 pb-4">
+        <VersionSwitcher />
         <Fragment key={root.$id}>{renderSidebarList(root.children)}</Fragment>
       </div>
       <Sheet onOpenChange={setIsOpen} open={isOpen}>
@@ -82,6 +84,7 @@ export const Sidebar = () => {
             <SearchButton onClick={() => setIsOpen(false)} />
           </SheetHeader>
           <div className="flex-1 overflow-y-auto px-4 pb-4">
+            <VersionSwitcher />
             {renderSidebarList(root.children)}
           </div>
         </SheetContent>