Remove serverless

README.md

@@ -303,7 +303,7 @@ flow run human_approval.flow.yaml
 
 **What happens?**
 - The flow sends an SMS for approval.
-- It pauses until a reply is received (via webhook or manual event).
+- It pauses until a reply is received (via HTTP endpoint or manual event).
 - When the human replies, the flow resumes and prints the result.
 
 ---
@@ -479,8 +479,8 @@ flow run cfo_daily_cash.flow.yaml
 
 ```yaml
 name: ecommerce_autopilot
-on: schedule.interval
-every: "1h"
+on: schedule.cron
+cron: "0 * * * *"  # Every hour
 
 vars:
   MIN_MARGIN_PCT: 20
@@ -617,7 +617,7 @@ steps:
 
 ✨ **Templating:** `{{…}}` gives you outputs, vars, secrets, helper funcs.
 
-⏳ **Durable waits:** `await_event` pauses until external approval / webhook.
+⏳ **Durable waits:** `await_event` pauses until external approval / HTTP event.
 
 ⚡ **Parallelism & retries:** `parallel: true` blocks and `retry:` back-offs.
 
@@ -686,7 +686,7 @@ BeemFlow provides **three complementary ways** to integrate with HTTP APIs and e
 **How it works:**
 - **Complete HTTP control** - any method, headers, body, authentication
 - **No assumptions** - you specify exactly what gets sent
-- **Perfect for** - REST APIs, webhooks, custom protocols
+- **Perfect for** - REST APIs, HTTP endpoints, custom protocols
 - **Raw power** - handles any HTTP scenario
 
 ### 🚀 Pattern 3: MCP Servers (For complex integrations)
@@ -725,7 +725,7 @@ BeemFlow provides **three complementary ways** to integrate with HTTP APIs and e
 | Custom REST API (advanced) | MCP server | `mcp://my-api/search` with caching, retries, etc. |
 | Database queries | MCP server | `mcp://postgres/query` |
 | File processing | MCP server | `mcp://filesystem/read` |
-| One-off webhook/custom request | Generic HTTP | `http` with custom headers |
+| One-off HTTP/custom request | Generic HTTP | `http` with custom headers |
 
 ### Testing All Patterns
 

adapter/http_adapter.go

@@ -10,15 +10,19 @@ import (
 	"os"
 	"regexp"
 	"strings"
-	"time"
 
 	"github.com/awantoch/beemflow/constants"
 	"github.com/awantoch/beemflow/registry"
 	"github.com/awantoch/beemflow/utils"
 )
 
-// defaultClient is used for HTTP requests with a timeout to avoid hanging.
-var defaultClient = &http.Client{Timeout: 30 * time.Second}
+// getHTTPClient returns an HTTP client that respects context deadlines
+func getHTTPClient() *http.Client {
+	return &http.Client{
+		// Don't set a timeout here - let the context handle timeouts
+		// This allows proper context cancellation and deadline handling
+	}
+}
 
 // Environment variable pattern for safe parsing
 var envVarPattern = regexp.MustCompile(`\$env:([A-Za-z_][A-Za-z0-9_]*)`)
@@ -148,8 +152,9 @@ func (a *HTTPAdapter) executeHTTPRequest(ctx context.Context, req HTTPRequest) (
 	}
 	httpReq.Header.Set(constants.HeaderAccept, constants.DefaultJSONAccept)
 
-	// Execute request
-	resp, err := defaultClient.Do(httpReq)
+	// Execute request with context-aware client
+	client := getHTTPClient()
+	resp, err := client.Do(httpReq)
 	if err != nil {
 		return nil, utils.Errorf("HTTP request failed: %w", err)
 	}

cmd/flow/main.go

@@ -141,11 +141,6 @@ func newServeCmd() *cobra.Command {
 			}
 
 			utils.Info("Starting BeemFlow HTTP server...")
-			// Skip actual server start in tests
-			if os.Getenv("BEEMFLOW_TEST") == "1" {
-				utils.User("flow serve (test mode)")
-				return
-			}
 			if err := beemhttp.StartServer(cfg); err != nil {
 				utils.Error("Failed to start server: %v", err)
 				exit(1)