Interface GeoScrapeService
- All Known Implementing Classes:
GeoScrapeServiceImpl
Deprecated.
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic classDeprecated.Outcome of a dry run: the candidates, plus the two things a batching caller cannot work out from the candidate list alone.static classDeprecated.Parameters for a single scrape run. -
Method Summary
Modifier and TypeMethodDescriptionDeprecated.Deprecated.Run a scrape.Deprecated.Evaluate matchers against the same windowscrape(ScrapeRequest)would inspect, but persist nothing — no watermark row, noPreboardedExperimentrow, no ticket.
-
Method Details
-
scrape
Deprecated.Run a scrape. Synchronous; intended to be invoked from aGeoScrapeTaskCommandrunning on the task-runner. HonorsThread.interrupted()between pages — the watermark row is markedGeoScrapeWatermark.Status.CANCELLEDif the worker is interrupted mid-scan.- Returns:
- the persisted watermark row covering this run (so the caller can summarize counts/timings).
-
scrapeDryRun
Deprecated.Evaluate matchers against the same windowscrape(ScrapeRequest)would inspect, but persist nothing — no watermark row, noPreboardedExperimentrow, no ticket. Intended for downstream callers (currently gemma-curation-agents) that mock-persist the results locally to evaluate curation methods without writing to prod gemd. Wire shape per candidate mirrors the existing preboarded GET response so the dry-run flag can flip off later without a shape change.- Returns:
- the candidate list in scan order;
dryRunon the request is ignored (treated astrueby contract).
-
getLastWatermark
Deprecated.- Returns:
- the most recent
GeoScrapeWatermarkrow, ornullif no scrape has ever been run.
-
scrape_geo_and_open_triage.py. The agent discovers candidates, decides what is worth preboarding, and opens its own triage ticket, so Gemma no longer needs to run the scrape itself.Nothing here is removed yet and it still works. What it does that the agent must therefore also do: it creates the
PreboardedExperimentrows, writes theGeoScrapeWatermarkaudit row, and opens ONESCREENINGticket per batch targeting that watermark -- deliberately not one per candidate.The preboarded write API the agent uses instead is
POST /preboarded+POST /preboarded/{id}/annotation-sets, withGET /workflow/queue?datasetType=preboarded_experimentfor the queue.