Workflows

export const userSignup = restate.workflow({
  name: "user-signup",
  handlers: {
    run: async (ctx: WorkflowContext, user: User) => {
      const userId = ctx.key; // unique workflow key

      // Use regular if/else, loops, and functions
      const success = await ctx.run("create", () => createUser(userId, user));
      if (!success) return { success };

      // Execute durable steps
      await ctx.run("activate", () => activateUser(userId));
      await ctx.run("welcome", () => sendWelcomeEmail(user));

      return { success: true };
    },
  },
});

@Workflow
public class UserSignup {

  @Workflow
  public boolean run(User user) {
    String userId = Restate.key(); // unique workflow key

    // Use regular if/else, loops, and functions
    boolean success = Restate.run("create", Boolean.class, () -> createUser(userId, user));
    if (!success) {
      return false;
    }

    // Execute durable steps
    Restate.run("activate", () -> activateUser(userId));
    Restate.run("welcome", () -> sendWelcomeEmail(user));

    return true;
  }
}

user_signup = restate.Workflow("user-signup")


@user_signup.main()
async def run(ctx: restate.WorkflowContext, user: User) -> Dict[str, bool]:
    # Unique workflow key
    user_id = ctx.key()

    # Use regular if/else, loops, and functions
    success = await ctx.run_typed("create", create_user, user_id=user_id, user=user)
    if not success:
        return {"success": False}

    # Execute durable steps
    await ctx.run_typed("activate", activate_user, user_id=user_id)
    await ctx.run_typed("welcome", send_welcome_email, user=user)

    return {"success": True}

type UserSignup struct{}

func (UserSignup) Run(ctx restate.WorkflowContext, user User) (bool, error) {
  // unique workflow key
  userID := restate.Key(ctx)

  // Use regular if/else, loops, and functions
  success, err := restate.Run(ctx, func(ctx restate.RunContext) (bool, error) {
    return CreateUser(userID, user)
  })
  if err != nil || !success {
    return false, err
  }

  // Execute durable steps
  _, err = restate.Run(ctx, func(ctx restate.RunContext) (restate.Void, error) {
    return ActivateUser(userID)
  })
  if err != nil {
    return false, err
  }

  _, err = restate.Run(ctx, func(ctx restate.RunContext) (restate.Void, error) {
    return SendWelcomeEmail(user)
  })
  if err != nil {
    return false, err
  }

  return true, nil
}