Spotify Scio (Scala-on-Beam) pipeline + ScalaTest. End-to-end CustomersPipeline.run writes 3 rows via Beam's BATCH_LOADS and the emulator returns them on read — closed in v1.0.2 via a per-example EmulatorBigQueryServices injected through BigQueryIO.Write.withTestServices(...) and a fsouza/fake-gcs-server sidecar for the GCS staging step (#17, ADR 0034).
Each example has its own job in
.github/workflows/examples.yml.
The job builds (or pulls) the dev image and runs the example's
make test. The examples workflow is not a required check on the
main pipeline — a flaky upstream dependency (dbt-core release, Spark
upgrade, etc.) should not block emulator PRs.