Temporal vs Zapier vs n8n: Enterprise Workflow Costs

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

@activity.defn
async def validate_payment(order_id: str, amount: float) -> dict:
    print(f"Validating payment for order {order_id}: ${amount}")
    # Simulating API call to payment processor
    return {"status": "approved", "transaction_id": f"txn_{order_id}"}

@activity.defn
async def reserve_inventory(order_id: str, items: list) -> dict:
    print(f"Reserving inventory for order {order_id}")
    # Simulating inventory system call
    return {"status": "reserved", "warehouse": "warehouse_1"}

@activity.defn
async def send_confirmation_email(order_id: str, email: str, amount: float) -> dict:
    print(f"Sending confirmation to {email}")
    # Simulating email service
    return {"status": "sent", "email": email}

@workflow.defn
class OrderProcessingWorkflow:
    @workflow.run
    async def run(self, order_data: dict) -> dict:
        payment_result = await workflow.execute_activity(
            validate_payment,
            args=[order_data["order_id"], order_data["amount"]],
            start_to_close_timeout=timedelta(seconds=30)
        )
        
        if payment_result["status"] != "approved":
            return {"status": "failed", "reason": "payment_declined"}
        
        inventory_result = await workflow.execute_activity(
            reserve_inventory,
            args=[order_data["order_id"], order_data["items"]],
            start_to_close_timeout=timedelta(seconds=30)
        )
        
        if inventory_result["status"] != "reserved":
            return {"status": "failed", "reason": "inventory_unavailable"}
        
        email_result = await workflow.execute_activity(
            send_confirmation_email,
            args=[order_data["order_id"], order_data["email"], order_data["amount"]],
            start_to_close_timeout=timedelta(seconds=30)
        )
        
        return {
            "status": "completed",
            "order_id": order_data["order_id"],
            "payment": payment_result,
            "inventory": inventory_result,
            "confirmation": email_result
        }

async def main():
    client = await Client.connect("localhost:7233")
    
    order = {
        "order_id": "ORDER_12345",
        "amount": 299.99,
        "items": ["WIDGET_A", "WIDGET_B"],
        "email": "customer@example.com"
    }
    
    result = await client.execute_workflow(
        OrderProcessingWorkflow.run,
        order,
        id="order-workflow-12345",
        task_queue="default"
    )
    
    print(f"Workflow result: {result}")

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

{
  "name": "Enterprise Order Sync",
  "nodes": [
    {
      "parameters": {
        "pollInterval": 3600
      },
      "name": "Check for New Orders",
      "type": "n8n-nodes-base.interval",
      "typeVersion": 1,
      "position": [
        250,
        300
      ]
    },
    {
      "parameters": {
        "resource": "contact",
        "operation": "get",
        "contactId": "={{$node[\"Transform Order Data\"].json.contactId}}"
      },
      "name": "Get Customer from HubSpot",
      "type": "n8n-nodes-base.hubspot",
      "typeVersion": 2,
      "position": [
        450,
        300
      ]
    },
    {
      "parameters": {
        "resource": "lead",
        "operation": "update",
        "leadId": "={{$node[\"Check Salesforce Exists\"].json.leadId}}",
        "updateFields": {
          "Status": "Processing",
          "Phone": "={{$node[\"Get Customer from HubSpot\"].json.phone}}"
        }
      },
      "name": "Update Salesforce Lead",
      "type": "n8n-nodes-base.salesforce",
      "typeVersion": 2,
      "position": [
        650,
        300
      ]
    },
    {
      "parameters": {
        "channel": "{{$node[\"Get Slack Channel\"].json.channelId}}",
        "text": "New order processed: {{$node[\"Transform Order Data\"].json.orderId}}\nCustomer: {{$node[\"Get Customer from HubSpot\"].json.firstName}} {{$node[\"Get Customer from HubSpot\"].json.lastName}}\nAmount: ${{$node[\"Transform Order Data\"].json.amount}}"
      },
      "name": "Post to Slack",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        850,
        300
      ]
    },
    {
      "parameters": {
        "jsCode": "return {\n  orderId: $input.first().json.id,\n  contactId: $input.first().json.customerId,\n  amount: $input.first().json.total,\n  status: 'new',\n  timestamp: new Date().toISOString()\n}"
      },
      "name": "Transform Order Data",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        350,
        300
      ]
    },
    {
      "parameters": {
        "resource": "lead",
        "operation": "search",
        "options": {
          "limit": 1
        },
        "searchField": "Phone",
        "searchValue": "={{$node[\"Get Customer from HubSpot\"].json.phone}}"
      },
      "name": "Check Salesforce Exists",
      "type": "n8n-nodes-base.salesforce",
      "typeVersion": 2,
      "position": [
        550,
        300
      ]
    },
    {
      "