-
Notifications
You must be signed in to change notification settings - Fork 6.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
docs(samples): Add Kafka to Dataflow snippet #12013
docs(samples): Add Kafka to Dataflow snippet #12013
Conversation
Here is the summary of changes. You are about to add 1 region tag.
This comment is generated by snippet-bot.
|
9cd2192
to
a6f1e0c
Compare
6356688
to
b4f0958
Compare
@@ -32,6 +33,9 @@ def setup_and_teardown() -> None: | |||
yield | |||
finally: | |||
bucket.delete(force=True) | |||
# Ensure that PipelineOptions subclasses have been cleaned up between tests | |||
# See https://github.com/apache/beam/issues/18197 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
😮
Looks like the linter is configured to ignore "self" type annotations, but not "cls". |
Updating linter rules on #12428 |
Description
Adds a snippet that shows how to write messages to Pub/Sub from Dataflow.
Bug: b/350789182
Doc bug: b/342015050
Checklist
nox -s py-3.9
(see Test Environment Setup)nox -s lint
(see Test Environment Setup)