From hex-pack
Execute Hex primary workflow: Core Workflow A. Use when implementing primary use case, building main features, or core integration tasks. Trigger with phrases like "hex main workflow", "primary task with hex".
How this skill is triggered — by the user, by Claude, or both
Slash command
/hex-pack:hex-core-workflow-aThis skill is limited to the following tools:
The summary Claude sees in its skill listing — used to decide when to auto-load this skill
Trigger Hex project runs from external orchestration tools (Airflow, Dagster, cron) with input parameters, status polling, and error handling. This is the primary integration pattern for embedding Hex in data pipelines.
Trigger Hex project runs from external orchestration tools (Airflow, Dagster, cron) with input parameters, status polling, and error handling. This is the primary integration pattern for embedding Hex in data pipelines.
import 'dotenv/config';
const TOKEN = process.env.HEX_API_TOKEN!;
const BASE = 'https://app.hex.tech/api/v1';
interface RunConfig {
projectId: string;
inputParams?: Record<string, any>;
updateCache?: boolean;
killRunning?: boolean;
}
async function triggerRun(config: RunConfig) {
const response = await fetch(`${BASE}/project/${config.projectId}/run`, {
method: 'POST',
headers: { 'Authorization': `Bearer ${TOKEN}`, 'Content-Type': 'application/json' },
body: JSON.stringify({
inputParams: config.inputParams || {},
updateCacheResult: config.updateCache ?? true,
killRunningExecution: config.killRunning ?? false,
}),
});
if (!response.ok) throw new Error(`Trigger failed: ${response.status} ${await response.text()}`);
return response.json();
}
async function runAndWait(config: RunConfig, timeoutMs = 600000): Promise<any> {
const { runId, projectId } = await triggerRun(config);
const startTime = Date.now();
while (Date.now() - startTime < timeoutMs) {
const res = await fetch(`${BASE}/project/${projectId}/run/${runId}`, {
headers: { 'Authorization': `Bearer ${TOKEN}` },
});
const status = await res.json();
switch (status.status) {
case 'COMPLETED': return { success: true, runId, duration: Date.now() - startTime };
case 'ERRORED': throw new Error(`Run ${runId} errored: ${status.statusMessage || 'unknown'}`);
case 'KILLED': throw new Error(`Run ${runId} was killed`);
default: await new Promise(r => setTimeout(r, 5000));
}
}
throw new Error(`Run ${runId} timed out after ${timeoutMs}ms`);
}
// Run multiple Hex projects in sequence (data pipeline)
async function runPipeline(steps: RunConfig[]) {
const results = [];
for (const step of steps) {
console.log(`Running: ${step.projectId}`);
const result = await runAndWait(step);
console.log(`Completed in ${result.duration}ms`);
results.push(result);
}
return results;
}
// Example: ETL pipeline
await runPipeline([
{ projectId: 'extract-project-id', inputParams: { date: '2025-01-01' } },
{ projectId: 'transform-project-id' },
{ projectId: 'load-project-id', updateCache: true },
]);
async function cancelRun(projectId: string, runId: string) {
const response = await fetch(`${BASE}/project/${projectId}/run/${runId}`, {
method: 'DELETE',
headers: { 'Authorization': `Bearer ${TOKEN}` },
});
console.log(`Cancelled run ${runId}: ${response.status}`);
}
| Error | Cause | Solution |
|---|---|---|
429 Too Many Requests | Rate limit (20/min, 60/hr) | Queue runs with delays |
| Run ERRORED | Project code failed | Check project logs in Hex UI |
| Run KILLED | Timeout or manual cancel | Increase timeout or fix slow queries |
404 | Project not published | Publish project before triggering runs |
For scheduled runs, see hex-core-workflow-b.
npx claudepluginhub flight505/skill-forge --plugin hex-packCreates, edits, and optimizes skills for Claude Code, including drafting, evaluating with test prompts, iterating on performance, and improving skill descriptions for better triggering accuracy.