Fix input detection.

apache · Oct 2, 2023 · a06f4ec · a06f4ec
1 parent 5d6dcee
commit a06f4ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/yaml/yaml_provider.py b/sdks/python/apache_beam/yaml/yaml_provider.py
@@ -169,7 +169,7 @@ 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():
+    if self._urns[typ] in self.schema_transforms():
       return bool(self.schema_transforms()[self._urns[type]].inputs)
     else:
       return super().requires_inputs(typ, args)