tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r498461732
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r497830780
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r497830780
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r497096331
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r497092701
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r496100904
##
File path: sdks/python/setup.py
##
@@ -141,7 +141,7 @@ def get_version():
# server, therefore list of allowed versions is very narrow.
#
tvalentyn commented on a change in pull request #12927:
URL: https://github.com/apache/beam/pull/12927#discussion_r496099516
##
File path: sdks/python/apache_beam/io/avroio.py
##
@@ -627,11 +627,19 @@ def write_record(self, writer, value):
writer.append(value)
+class