diff --git a/core/src/test/java/google/registry/beam/invoicing/InvoicingPipelineTest.java b/core/src/test/java/google/registry/beam/invoicing/InvoicingPipelineTest.java index bb7a4e14b..14ec458df 100644 --- a/core/src/test/java/google/registry/beam/invoicing/InvoicingPipelineTest.java +++ b/core/src/test/java/google/registry/beam/invoicing/InvoicingPipelineTest.java @@ -289,7 +289,7 @@ class InvoicingPipelineTest { setTmForTest(jpaTm()); setupCloudSql(); PCollection billingEvents = InvoicingPipeline.readFromCloudSql(options, pipeline); - billingEvents = billingEvents.apply(new changeDomainRepo()); + billingEvents = billingEvents.apply(new ChangeDomainRepo()); PAssert.that(billingEvents).containsInAnyOrder(INPUT_EVENTS); pipeline.run().waitUntilFinish(); removeTmOverrideForTest(); @@ -590,7 +590,7 @@ class InvoicingPipelineTest { return persistResource(billingEventBuilder.build()); } - private static class changeDomainRepo + private static class ChangeDomainRepo extends PTransform, PCollection> { @Override public PCollection expand(PCollection input) {