Trigger and verify locally

import os
from render_sdk import Render

render = Render()

slug = os.getenv("WORKFLOW_SLUG", "local/merge_customer_data")
result = render.workflows.run_task(slug, [])
data = result.results

print(f"Generated {data['profiles_generated']} profiles across {data['shards_processed']} shards")
print(f"Avg health score: {data['statistics']['avg_health_score']}")
print(f"Churn distribution: {data['statistics']['churn_distribution']}")
print(f"Sample profile keys: {sorted((data['sample_profile'] or {}).keys())}")

assert data["profiles_generated"] == 1000, f"expected 1000 profiles, got {data['profiles_generated']}"
print("OK")

import { Render } from "@renderinc/sdk";

const render = new Render();

const slug = process.env.WORKFLOW_SLUG ?? "local/merge_customer_data";
const started = await render.workflows.startTask(slug, []);
const finished = await started.get();
const data = finished.results as {
  profiles_generated: number;
  shards_processed: number;
  sample_profile: Record<string, unknown> | null;
  statistics: { avg_health_score: number; churn_distribution: Record<string, number> };
};

console.log(`Generated ${data.profiles_generated} profiles across ${data.shards_processed} shards`);
console.log(`Avg health score: ${data.statistics.avg_health_score}`);
console.log(`Churn distribution: ${JSON.stringify(data.statistics.churn_distribution)}`);
console.log(`Sample profile keys: ${Object.keys(data.sample_profile ?? {}).sort().join(", ")}`);

if (data.profiles_generated !== 1000) {
  throw new Error(`expected 1000 profiles, got ${data.profiles_generated}`);
}
console.log("OK");