Scan for unprocessed raw data and queue it for ingestion
Scan for unprocessed raw data and queue it for ingestion
Queue every not-yet-processed raw-data record in a project.
Designed to be called on a schedule. Returns immediately after enqueuing; parsing and validation happen on the task worker. Safe to call concurrently — each record is claimed before it is enqueued, so overlapping runs cannot process the same file twice.
Scan for unprocessed raw data and queue it for ingestion
Query Parameters
Project to scan