feat: async workflows

apps/tests/aws-runtime/scripts/test-cli

@@ -8,22 +8,22 @@ npx eventual list services
 
 npx eventual list workflows
 
-npx eventual list executions 
+npx eventual start workflow sleepy
+
+npx eventual start workflow sleepy -f
+
+npx eventual list executions
 
-npx eventual list executions --workflow parallel --json > .eventual/out.json
+npx eventual list executions --workflow sleepy --json > .eventual/out.json
 
 execution_id=$(node -p 'JSON.parse(require("fs").readFileSync(".eventual/out.json").toString("utf8")).executions[0].id')
 
 npx eventual get history -e ${execution_id}
 
 npx eventual get logs --all
 
-npx eventual get logs --workflow parallel
+npx eventual get logs --workflow sleepy
 
 npx eventual get logs --execution ${execution_id}
 
-npx eventual start workflow sleepy
-
-npx eventual start workflow sleepy -f
-
 npx eventual replay execution ${execution_id} --entry 'test/test-service.ts'

packages/@eventual/cli/src/commands/replay.ts

@@ -7,19 +7,19 @@ import {
   isSucceededExecution,
 } from "@eventual/core";
 import {
+  isFailed,
+  isResolved,
+  normalizeFailedResult,
   parseWorkflowName,
   processEvents,
   progressWorkflow,
+  resultToString,
 } from "@eventual/core-runtime";
 import {
   encodeExecutionId,
-  isFailed,
-  isResolved,
-  normalizeFailedResult,
   Result,
-  resultToString,
   ServiceType,
-  serviceTypeScopeSync,
+  serviceTypeScope,
   workflows,
 } from "@eventual/core/internal";
 import path from "path";
@@ -62,7 +62,7 @@ export const replay = (yargs: Argv) =>
         }
         spinner.start("Running program");
 
-        serviceTypeScopeSync(ServiceType.OrchestratorWorker, () => {
+        await serviceTypeScope(ServiceType.OrchestratorWorker, async () => {
           const processedEvents = processEvents(
             events,
             [],
@@ -74,7 +74,11 @@ export const replay = (yargs: Argv) =>
             )
           );
 
-          const res = progressWorkflow(execution, workflow, processedEvents);
+          const res = await progressWorkflow(
+            execution,
+            workflow,
+            processedEvents
+          );
 
           assertExpectedResult(executionObj, res.result);
 

packages/@eventual/compiler/src/ast-util.ts

@@ -1,17 +1,11 @@
 import {
-  Argument,
-  ArrowFunctionExpression,
   CallExpression,
+  ComputedPropName,
   Expression,
-  FunctionExpression,
-  Span,
-  Node,
-  StringLiteral,
-  FunctionDeclaration,
-  Statement,
   HasSpan,
   Identifier,
-  ComputedPropName,
+  Node,
+  Span,
 } from "@swc/core";
 
 /**
@@ -101,67 +95,6 @@ function isId<Value extends string>(
   );
 }
 
-/**
- * A heuristic for identifying a {@link CallExpression} that is a call
- * to the eventual.workflow utility:
- *
- * 1. must be a function call with exactly 2 arguments
- * 2. first argument is a string literal
- * 3. second argument is a FunctionExpression or ArrowFunctionExpression
- * 4. callee is an identifier `"workflow"` or `<identifier>.workflow`
- */
-export function isWorkflowCall(call: CallExpression): call is CallExpression & {
-  arguments: [
-    Argument & { expression: StringLiteral },
-    Argument & { expression: FunctionExpression | ArrowFunctionExpression }
-  ];
-} {
-  return (
-    isWorkflowCallee(call.callee) &&
-    call.arguments[0]?.expression.type === "StringLiteral" &&
-    ((call.arguments.length === 2 &&
-      isNonGeneratorFunction(call.arguments[1]?.expression)) ||
-      (call.arguments.length === 3 &&
-        isNonGeneratorFunction(call.arguments[2]?.expression)))
-  );
-}
-
-export function isNonGeneratorFunction(
-  expr?: Expression
-): expr is ArrowFunctionExpression | FunctionExpression {
-  return (
-    (expr?.type === "ArrowFunctionExpression" ||
-      expr?.type === "FunctionExpression") &&
-    !expr.generator
-  );
-}
-
-export function isActivityCallee(callee: CallExpression["callee"]) {
-  return isCallee("activity", callee);
-}
-
-export function isWorkflowCallee(callee: CallExpression["callee"]) {
-  return isCallee("workflow", callee);
-}
-
-export function isCallee(
-  type: "activity" | "workflow",
-  callee: CallExpression["callee"]
-) {
-  return (
-    (callee.type === "Identifier" && callee.value === type) ||
-    (callee.type === "MemberExpression" &&
-      callee.property.type === "Identifier" &&
-      callee.property.value === type)
-  );
-}
-
-export function isAsyncFunctionDecl(
-  stmt: Statement
-): stmt is FunctionDeclaration & { async: true } {
-  return stmt.type === "FunctionDeclaration" && stmt.async;
-}
-
 export function hasSpan(expr: Node): expr is Node & HasSpan {
   return "span" in expr;
 }

packages/@eventual/compiler/src/eventual-bundle.ts

@@ -4,7 +4,6 @@ import { aliasPath } from "esbuild-plugin-alias-path";
 import fs from "fs/promises";
 import path from "path";
 import { prepareOutDir } from "./build.js";
-import { eventualESPlugin } from "./esbuild-plugin.js";
 
 export async function bundleSources(
   outDir: string,
@@ -65,7 +64,6 @@ export async function build({
   injectedServiceSpec,
   name,
   entry,
-  eventualTransform = false,
   sourcemap,
   serviceType,
   external,
@@ -102,7 +100,6 @@ export async function build({
             }),
           ]
         : []),
-      ...(eventualTransform ? [eventualESPlugin] : []),
     ],
     conditions: ["module", "import", "require"],
     // external: ["@aws-sdk"],

packages/@eventual/compiler/src/index.ts

@@ -1,5 +1,3 @@
 export * from "./eventual-bundle.js";
 export * from "./eventual-infer.js";
-export * from "./esbuild-plugin.js";
 export * from "./build.js";
-export * from "./workflow-visitor.js";