Function fetchInngestRunsForEvent

apps/api/src/service.ts:105–127

(
	eventId: string,
)

/** Fetch runs for a single event (GET /v1/events/{eventId}/runs) – runs are the actual jobs */
export const fetchInngestRunsForEvent = async (
	eventId: string,
): Promise<InngestRun[]> => {
	const res = await fetch(
		`${baseUrl}/v1/events/${encodeURIComponent(eventId)}/runs`,
		{
			headers: {
				Authorization: `Bearer ${signingKey}`,
				"Content-Type": "application/json",
			},
		},
	);
	if (!res.ok) {
		logger.warn("Inngest runs API error", {
			eventId,
			status: res.status,
			body: await res.text(),
		});
		return [];
	}
	const body = (await res.json()) as { data?: InngestRun[] };
	return Array.isArray(body.data) ? body.data : [];
};

/** One row for the queue UI (BullMQ-compatible shape) */
export type DeploymentJobRow = {