diff --git a/core/src/main/java/google/registry/beam/resave/ResaveAllEppResourcesPipeline.java b/core/src/main/java/google/registry/beam/resave/ResaveAllEppResourcesPipeline.java index 014e1e9fd..52a9bd827 100644 --- a/core/src/main/java/google/registry/beam/resave/ResaveAllEppResourcesPipeline.java +++ b/core/src/main/java/google/registry/beam/resave/ResaveAllEppResourcesPipeline.java @@ -33,6 +33,7 @@ import java.io.Serializable; import java.util.concurrent.ThreadLocalRandom; import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.PipelineResult; +import org.apache.beam.sdk.options.PipelineOptionsFactory; import org.apache.beam.sdk.transforms.DoFn; import org.apache.beam.sdk.transforms.GroupIntoBatches; import org.apache.beam.sdk.transforms.ParDo; @@ -172,4 +173,13 @@ public class ResaveAllEppResourcesPipeline implements Serializable { resource.cloneProjectedAtTime(jpaTm().getTransactionTime())))); } } + + public static void main(String[] args) { + PipelineOptionsFactory.register(ResaveAllEppResourcesPipelineOptions.class); + ResaveAllEppResourcesPipelineOptions options = + PipelineOptionsFactory.fromArgs(args) + .withValidation() + .as(ResaveAllEppResourcesPipelineOptions.class); + new ResaveAllEppResourcesPipeline(options).run(); + } }