Sleep

import { serve } from "@upstash/workflow/nextjs";

export const { POST } = serve<string>(async (context) => {
  const { userId } = context.requestPayload;

  // Send welcome email immediately
  await context.run("send-welcome-email", async () => {
    return await sendWelcomeEmail(userId);
  });

  // Wait for 3 days before sending follow-up
  await context.sleep("wait-for-follow-up", "3d");

  // Send follow-up email
  await context.run("send-follow-up-email", async () => {
    return await sendFollowUpEmail(userId);
  });
});

from fastapi import FastAPI
from upstash_workflow.fastapi import Serve
from upstash_workflow import AsyncWorkflowContext

app = FastAPI()
serve = Serve(app)

@serve.post("/api/onboarding")
async def onboarding(context: AsyncWorkflowContext[str]) -> None:
    user_id = context.request_payload["user_id"]
    
    # Send welcome email immediately
    async def _send_welcome_email():
        return await send_welcome_email(user_id)
    
    await context.run("send-welcome-email", _send_welcome_email)
    
    # Wait for 3 days before sending follow-up
    await context.sleep("wait-for-follow-up", "3d")
    
    # Send follow-up email
    async def _send_follow_up_email():
        return await send_follow_up_email(user_id)
    
    await context.run("send-follow-up-email", _send_follow_up_email)

import { serve } from "@upstash/workflow/nextjs";

export const { POST } = serve<string>(async (context) => {
  const { userId, scheduledTime } = context.requestPayload;

  // Calculate the scheduled time
  const scheduledDate = new Date(scheduledTime);

  // Wait until the scheduled time
  await context.sleepUntil("wait-until-scheduled", scheduledDate);

  // Execute the scheduled task
  await context.run("execute-scheduled-task", async () => {
    return await executeTask(userId);
  });
});

from fastapi import FastAPI
from upstash_workflow.fastapi import Serve
from upstash_workflow import AsyncWorkflowContext
from datetime import datetime

app = FastAPI()
serve = Serve(app)

@serve.post("/api/scheduled-task")
async def scheduled_task(context: AsyncWorkflowContext[str]) -> None:
    user_id = context.request_payload["user_id"]
    scheduled_time = context.request_payload["scheduled_time"]
    
    # Calculate the scheduled time
    scheduled_date = datetime.fromisoformat(scheduled_time)
    
    # Wait until the scheduled time
    await context.sleep_until("wait-until-scheduled", scheduled_date)
    
    # Execute the scheduled task
    async def _execute_task():
        return await execute_task(user_id)
    
    await context.run("execute-scheduled-task", _execute_task)