hjtran commented on code in PR #35224:
URL: https://github.com/apache/beam/pull/35224#discussion_r2138438940
##########
sdks/python/apache_beam/pipeline.py:
##########
@@ -766,6 +766,12 @@ def apply(
'streaming jobs.' % full_label)
self.applied_labels.add(full_label)
+ if pvalueish is None:
+ full_label = self._current_transform().full_label
+ raise TypeCheckError(
+ f'Transform "{full_label}" was applied to the output of '
+ f'an object of type None.')
+
Review Comment:
Bummer to lose the name of the transform that produced the "None", but
doesn't look like there's an easy way to capture that.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
