DBOS vs. Temporal

# Annotate what you already have
@DBOS.step()
def validate_payment(): ...


@DBOS.step()
def ship_order(): ...


@DBOS.workflow()
def checkout_workflow():
    validate_payment()
    check_inventory()
    ship_order()
    notify_customer()

import asyncio
from datetime import timedelta
from temporalio import activity, workflow
from temporalio.client import Client
from temporalio.worker import Worker

# 1. Define Activities (Equivalent to DBOS Steps)
@activity.defn
async def validate_payment() -> str:
    pass

@activity.defn
async def check_inventory() -> str:
    pass

@activity.defn
async def ship_order() -> str:
    pass

@activity.defn
async def notify_customer() -> str:
    pass

# 2. Define the Workflow
# Temporal requires workflows to be defined as classes with a run method
@workflow.defn
class CheckoutWorkflow:
    @workflow.run
    async def run(self) -> None:
        # Activities must be explicitly awaited and require timeout configurations
        await workflow.execute_activity(
            validate_payment,
            start_to_close_timeout=timedelta(seconds=10),
        )
        await workflow.execute_activity(
            check_inventory,
            start_to_close_timeout=timedelta(seconds=10),
        )
        await workflow.execute_activity(
            ship_order,
            start_to_close_timeout=timedelta(seconds=10),
        )
        await workflow.execute_activity(
            notify_customer,
            start_to_close_timeout=timedelta(seconds=10),
        )

# 3. Setup the Client and Worker
# This is the boilerplate required to connect your code to the Temporal Server, 
# which in turn talks to the Cassandra/Postgres datastore.
async def main():
    # Connect to the Temporal server (assuming it is running locally or via Cloud)
    client = await Client.connect("localhost:7233")

    # Initialize and run the worker to host the workflow and activities
    worker = Worker(
        client,
        task_queue="checkout-task-queue",
        workflows=[CheckoutWorkflow],
        activities=[validate_payment, check_inventory, ship_order, notify_customer],
    )
    
    print("Worker starting. Listening to Temporal Server...")
    await worker.run()

if __name__ == "__main__":
    asyncio.run(main())