We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 03e11a4 commit 04e26a7Copy full SHA for 04e26a7
1 file changed
src/nypl_py_utils/classes/avro_client.py
@@ -1,5 +1,4 @@
1
import avro.schema
2
-import base64
3
import requests
4
5
from avro.errors import AvroException
@@ -130,10 +129,8 @@ def decode_record(self, record):
130
129
rec=record, schema=self.schema.name
131
)
132
133
- bytes_input = base64.b64decode(record) if (
134
- isinstance(record, str)) else record
135
datum_reader = DatumReader(self.schema)
136
- with BytesIO(bytes_input) as input_stream:
+ with BytesIO(record) as input_stream:
137
decoder = BinaryDecoder(input_stream)
138
try:
139
return datum_reader.read(decoder)
0 commit comments