-
Notifications
You must be signed in to change notification settings - Fork 4.2k
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
Fix BigQuery RowAsDictJsonCoder output type in Python 3 #7727
Conversation
R: @tvalentyn @aaltay |
Run Python Postcommit |
Run Python PostCommit |
Run Python Postcommit |
Run Python Postcommit |
Run Portable_Python PreCommit |
Run Python PreCommit |
a3f75b5
to
65c9759
Compare
except ValueError as e: | ||
raise ValueError('%s. %s' % (e, JSON_COMPLIANCE_ERROR)) | ||
|
||
def decode(self, encoded_table_row): | ||
return json.loads(encoded_table_row) | ||
return json.loads(encoded_table_row.decode('utf-8')) |
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.
Could you please check that this works with Tornadoes example on DirectRunner?
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.
Yes, this continues to work with both DirectRunner and DataflowRunner.
This change allows the BigQuery tornadoes example pipeline to run on Dataflow with Python 3.
Follow this checklist to help us incorporate your contribution quickly and easily:
[BEAM-XXX] Fixes bug in ApproximateQuantiles
, where you replaceBEAM-XXX
with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.It will help us expedite review of your Pull Request if you tag someone (e.g.
@username
) to look at it.Post-Commit Tests Status (on master branch)