Function: ingestJobSignals()

ingestJobSignals(companyId, rawPayloads): Promise<IngestSummary>

Defined in: src/server/services/pipeline.ts:115

Ingest a batch of normalized postings for one company. Idempotent: re-running the same batch refreshes last_seen_at instead of creating duplicates (unique on source+external_id, plus the facility+role sibling window). Returns counts for the cron/script summary.

Parameters

companyId

string

rawPayloads

unknown

Returns

Promise<IngestSummary>