Fix input detection. (#28775)

apache · Oct 2, 2023 · 11e2bae · 11e2bae
1 parent 4a9608d
commit 11e2bae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py b/sdks/python/apache_beam/yaml/yaml_provider.py
@@ -169,8 +169,8 @@ def config_schema(self, type):
           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)