diff --git a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/pubsub/PubSubSource.java b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/pubsub/PubSubSource.java
index 2defde3f0ded50d7bf6edf1479589ba3d9943bfe..7155b4a6d8d89d66278ae4d6241a9db458fe42e9 100644
--- a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/pubsub/PubSubSource.java
+++ b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/pubsub/PubSubSource.java
@@ -45,7 +45,8 @@ public final class PubSubSource extends PTransform<PBegin, PCollection<ActivePow
       final String subscriptionName) {
     return new PubSubSource(PubsubIO
         .readMessages()
-        .fromTopic(PubSubSubscriptionFactory.create(projectName, subscriptionName).asPath()));
+        .fromSubscription(
+            PubSubSubscriptionFactory.create(projectName, subscriptionName).asPath()));
   }
 
 }