[beam] branch master updated: Fix input detection. (#28775)

[robertwb]

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 11e2bae4cbe Fix input detection. (#28775)
11e2bae4cbe is described below

commit 11e2bae4cbee4cc4f9d200a71511d921e8591dcd
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Mon Oct 2 13:38:48 2023 -0700

    Fix input detection. (#28775)
---
 sdks/python/apache_beam/yaml/yaml_provider.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py 
b/sdks/python/apache_beam/yaml/yaml_provider.py
index 3a88f6074b3..630e63c31d8 100644
--- a/sdks/python/apache_beam/yaml/yaml_provider.py
+++ b/sdks/python/apache_beam/yaml/yaml_provider.py
@@ -169,8 +169,8 @@ class ExternalProvider(Provider):
           self.schema_transforms()[self._urns[type]].configuration_schema)
 
   def requires_inputs(self, typ, args):
-    if self._urns[type] in self.schema_transforms():
-      return bool(self.schema_transforms()[self._urns[type]].inputs)
+    if self._urns[typ] in self.schema_transforms():
+      return bool(self.schema_transforms()[self._urns[typ]].inputs)
     else:
       return super().requires_inputs(typ, args)