Workflows-as-code

Lightweight, flexible, durable.

Combine the resiliency of workflows with the speed and flexibility of regular functions.
Restate orchestrates and manages their execution till completion, whether it’s millis or months.

Just code

Get workflow-like semantics for any function: retries, recovery of progress,... Restate provides a distributed, durable version of familiar building blocks: timers, promises, signals,...

Low latency

Restate is built from the ground up to serve low-latency workflows. You can now put workflows in the latency-sensitive path of user interactions.

Deploy on FaaS

Run (parts of) your workflow on AWS Lambda. Restate lets your Lambda function suspend whenever its waiting on inputs.

Workflows with Restate

Implement the run function of your workflow, using the Restate SDK.

TypeScript
Java
Kotlin

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Persist progress

Store results of intermediate steps, interaction with external systems, or non-deterministic actions. Restate makes sure that on retries, the code does not get re-executed and the previous result is returned. This lets you execute the steps of your workflows durably.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Workflow state

Use Restate’s built-in key-value store to store workflow state. Restate guarantees that it is consistent and persistent, since state updates are tracked together with the rest of the execution progress.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

Persist progress

Workflow state

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

user_sign_up_flow.ts


const signUpWorkflow = restate.workflow({
  name: "sign-up-workflow",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const { id, name, email } = user;
      ctx.set("stage", "Creating User");
      await ctx.run(() => createUserEntry({ id, name }));
      ctx.set("stage", "Email Verification");
      const secret = ctx.rand.uuidv4();
      await ctx.run(() => sendEmailWithLink({ email, secret }));
      const clickSecret = await ctx.promise<string>("email-link");
      if (clickSecret !== secret) {
        ctx.set("stage", `Verification failed`);
        throw new TerminalError("Wrong secret from email link");
      }
      ctx.set("stage", "User verified");
      return true;
    },
    getStage: (ctx: WorkflowSharedContext) => ctx.get("stage"),
    approveEmail: (ctx: WorkflowSharedContext, secret: string) =>
      ctx.promise<string>("email-link").resolve(secret),
    rejectEmail: (ctx: WorkflowSharedContext) =>
      ctx.promise<string>("email-link").reject("Abort verification"),
  },
});

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Persist progress

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Workflow state

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

Persist progress

Workflow state

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

SignupWorkflow.java


@Workflow
public class SignupWorkflow {
  private final StateKey<String> STAGE = StateKey.of("stage", JsonSerdes.STRING);
  private final DurablePromiseKey<String> EMAIL_LINK =
      DurablePromiseKey.of("email-link", JsonSerdes.STRING);
  @Workflow
  public boolean run(WorkflowContext ctx, User user) {
    ctx.set(STAGE, "Creating user");
    ctx.run(() -> createUserEntry(ctx.key(), user.getName()));
    ctx.set(STAGE, "Email verification");
    String secret = ctx.random().nextUUID().toString();
    ctx.run(() -> sendEmailWithLink(user.getEmail(), secret));
    String clickSecret = ctx.promise(EMAIL_LINK).awaitable().await();
    if (!clickSecret.equals(secret)) {
      ctx.set(STAGE, "Verification failed");
      throw new TerminalException("Wrong secret from email link");
    }
    ctx.set(STAGE, "User verified");
    return true;
  }
  @Handler
  public String getStage(SharedWorkflowContext ctx) {
    return ctx.get(STAGE).orElse("Unknown");
  }
  @Handler
  public void approveEmail(SharedWorkflowContext ctx, String secret) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret);
  }
  @Handler
  public void rejectEmail(SharedWorkflowContext ctx) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification");
  }
}

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Persist progress

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Workflow state

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

Run once, idempotently

A workflow runs exactly one time. Restate makes sure that duplicate requests do not lead to duplicate execution.

Persist progress

Workflow state

Query workflow state

Retrieve the current state of the workflow from within other handlers and expose it to external clients.

Wait on external signals

Make Promises/Futures resilient by registering them in Restate. Share them and wait until other functions resolve them.

Signal in-flight workflows

Notify the workflow of external signals, callbacks or Kafka events. Resolve or reject shared promises on which the workflow is waiting. The workflow handles the outcome.

Flexible failure handling

Implement sagas and compensations in code, as per your requirements.

SignupWorkflow.kt


@Workflow
class SignupWorkflow {
  companion object {
    private val STAGE = KtStateKey.json<String>("stage")
    private val EMAIL_LINK = KtDurablePromiseKey.json<String>("email-link")
  }
  @Workflow
  suspend fun run(ctx: WorkflowContext, user: User): Boolean {
    ctx.set(STAGE, "Creating user")
    ctx.runBlock { createUserEntry(ctx.key(), user.name) }
    ctx.set(STAGE, "Email verification")
    val secret = ctx.random().nextUUID().toString()
    ctx.runBlock { sendEmailWithLink(user.email, secret) }
    val clickSecret = ctx.promise(EMAIL_LINK).awaitable().await()
    if (clickSecret != secret) {
      ctx.set(STAGE, "Verification failed")
      throw TerminalException("Wrong secret from email link")
    }
    ctx.set(STAGE, "User verified")
    return true
  }
  @Handler
  suspend fun getStage(ctx: SharedWorkflowContext): String? {
    return ctx.get(STAGE)
  }
  @Handler
  suspend fun approveEmail(ctx: SharedWorkflowContext, secret: String) {
    ctx.promiseHandle(EMAIL_LINK).resolve(secret)
  }
  @Handler
  suspend fun rejectEmail(ctx: SharedWorkflowContext) {
    ctx.promiseHandle(EMAIL_LINK).reject("Abort verification")
  }
}

LOW-LATENCY

Restate’s event-driven foundation built in Rust lets you put workflows in the latency-sensitive path of user interaction.

DURABLE EXECUTION

Restate handles retries and recovers your code to the exact point before the crash. No more coarse per-step retries. State changes take part in durable execution, so the state never gets out of sync.

TypeScript
Java
Kotlin

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

submit.ts


// import * as clients from "@restatedev/restate-sdk-clients";
const rs = clients.connect({ url: "http://localhost:8080" });
await rs
  .workflowClient<SignUpWorkflow>({ name: "sign-up-workflow" }, user.id)
  .workflowSubmit(user);
// do something else, with workflow running in the background
// attach back to the workflow
const result = await rs
  .workflowClient<SignUpWorkflow>({ name: "sign-up-workflow" }, user.id)
  .workflowAttach();

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

submit.ts


// import * as clients from "@restatedev/restate-sdk-clients";
const rs = clients.connect({ url: "http://localhost:8080" });
await rs
  .workflowClient<SignUpWorkflow>({ name: "sign-up-workflow" }, user.id)
  .workflowSubmit(user);
// do something else, with workflow running in the background
// attach back to the workflow
const result = await rs
  .workflowClient<SignUpWorkflow>({ name: "sign-up-workflow" }, user.id)
  .workflowAttach();

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

WorkflowSubmitter.java


// import dev.restate.sdk.client.Client;
Client rs = Client.connect("http://localhost:8080");
SignupWorkflowClient.fromClient(rs, user.getId())
    .submit(user);
// do something else, with workflow running in the background
// attach back to the workflow
boolean result =
    SignupWorkflowClient.fromClient(rs, user.getId())
        .workflowHandle()
        .attach();

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

WorkflowSubmitter.java


// import dev.restate.sdk.client.Client;
Client rs = Client.connect("http://localhost:8080");
SignupWorkflowClient.fromClient(rs, user.getId())
    .submit(user);
// do something else, with workflow running in the background
// attach back to the workflow
boolean result =
    SignupWorkflowClient.fromClient(rs, user.getId())
        .workflowHandle()
        .attach();

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

WorkflowSubmitter.kt


// import dev.restate.sdk.client.Client;
val rs = Client.connect("http://localhost:8080")
SignupWorkflowClient.fromClient(rs, user.id)
    .submit(user)
// do something else, with workflow running in the background
// attach back to the workflow
val result =
    SignupWorkflowClient.fromClient(rs, user.id)
        .workflowHandle()
        .attach()

Latch on to a workflow

A workflow runs exactly one time. If the caller loses the connection to the workflow, he can latch on again to retrieve the result.

WorkflowSubmitter.kt


// import dev.restate.sdk.client.Client;
val rs = Client.connect("http://localhost:8080")
SignupWorkflowClient.fromClient(rs, user.id)
    .submit(user)
// do something else, with workflow running in the background
// attach back to the workflow
val result =
    SignupWorkflowClient.fromClient(rs, user.id)
        .workflowHandle()
        .attach()

Workflows as regular, lightweight functions

Restate’s workflow functionality is integrated in its core.
Workflows run like any other function in your infrastructure: on K8S, FaaS, or mix-and-match.
No need to spin up extra infrastructure or dedicated workers.

What you can build with Workflows and Restate

User sign-up workflow

Create user in the system, wait until email confirmation, schedule a reminder, send welcome email, etc.

Order processing and logistics

Handle the payment, request the order preparation, wait for driver acceptance callback, etc.

Infrastructure provisioning

Go through a set of steps to provision a setup. Retry until resources are up, handle timeouts, rollbacks, etc.

Workflow interpreters

Dynamically compose workflows based on user input. For example, an image transformer that lets users specify the steps to be taken.

Wondering about a specific use case?

Let’s brainstorm together on Discord

Developer Resources

Blog post

We replaced 400 lines of StepFunctions ASL with 40 lines of TypeScript by making Lambdas suspendable.

Docs

Read the docs to learn more.

Need help?

Join the Restate Discord channel

Workflows-as-code

Lightweight, flexible, durable.

Just code

Low latency

Deploy on FaaS

Workflows with Restate​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

Run once, idempotently​

Persist progress​

Workflow state​

Query workflow state​

Wait on external signals​

Signal in-flight workflows​

Flexible failure handling​

LOW-LATENCY

DURABLE EXECUTION

Latch on to a workflow​

Latch on to a workflow​

Latch on to a workflow​

Latch on to a workflow​

Latch on to a workflow​

Latch on to a workflow​

Workflows as regular, lightweight functions

What you can build with Workflows and Restate​

User sign-up workflow

Order processing and logistics

Infrastructure provisioning

Workflow interpreters

Wondering about a specific use case?

Developer Resources​

Blog post

Docs

Need help?

Workflows with Restate

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Run once, idempotently

Persist progress

Workflow state

Query workflow state

Wait on external signals

Signal in-flight workflows

Flexible failure handling

Latch on to a workflow

Latch on to a workflow

Latch on to a workflow

Latch on to a workflow

Latch on to a workflow

Latch on to a workflow

What you can build with Workflows and Restate

Developer Resources