Using the proper pipeline object for telemetry.

PiperOrigin-RevId: 441318280

Author: iindyk

Diff for: tensorflow_transform/beam/impl.py

@@ -1081,8 +1081,8 @@ def expand(self, dataset):
 
     # Gather telemetry on types of input features.
     _ = (
-        self.pipeline | 'CreateAnalyzeInputTensorRepresentations' >>
-        beam.Create([input_tensor_adapter_config.tensor_representations])
+        pipeline | 'CreateAnalyzeInputTensorRepresentations' >> beam.Create(
+            [input_tensor_adapter_config.tensor_representations])
         |
         'InstrumentAnalyzeInputTensors' >> telemetry.TrackTensorRepresentations(
             telemetry_util.AppendToNamespace(beam_common.METRICS_NAMESPACE,