bugfix: wrong invocation of SchemaParseException (#376)

confluent_kafka/avro/load.py

@@ -27,7 +27,7 @@ def loads(schema_str):
             return schema.parse(schema_str)
         else:
             return schema.Parse(schema_str)
-    except schema.AvroException.SchemaParseException as e:
+    except schema.SchemaParseException as e:
         raise ClientError("Schema parse failed: %s" % (str(e)))
 
 

setup.py

@@ -1,5 +1,6 @@
 #!/usr/bin/env python
 
+import os
 from setuptools import setup, find_packages
 from distutils.core import Extension
 import sys
@@ -14,6 +15,16 @@
                             'confluent_kafka/src/Producer.c',
                             'confluent_kafka/src/Consumer.c'])
 
+
+def get_install_requirements(path):
+    content = open(os.path.join(os.path.dirname(__file__), path)).read()
+    return [
+        req
+        for req in content.split("\n")
+        if req != '' and not req.startswith('#')
+    ]
+
+
 setup(name='confluent-kafka',
       version='0.11.4',
       description='Confluent\'s Apache Kafka client for Python',
@@ -24,5 +35,6 @@
       packages=find_packages(exclude=("tests", "tests.*")),
       data_files=[('', ['LICENSE.txt'])],
       extras_require={
-          'avro': ['fastavro', 'requests', avro]
+          'avro': ['fastavro', 'requests', avro],
+          'dev': get_install_requirements("test-requirements.txt")
       })

test-requirements.txt

@@ -0,0 +1,2 @@
+pytest
+flake8

tests/avro/invalid_scema.avsc

@@ -0,0 +1,10 @@
+{
+  "type" : "record",
+  "name" : "string_key",
+  "namespace" : "OrbitDbProducer",
+  "fields" : [ {
+    "name" : "key",
+    "type" : "array",
+    "items": "string"
+  } ]
+}

tests/avro/test_util.py

@@ -21,7 +21,7 @@
 #
 
 import unittest
-
+import pytest
 from avro import schema
 from tests.avro import data_gen
 from confluent_kafka import avro
@@ -35,3 +35,8 @@ def test_schema_from_string(self):
     def test_schema_from_file(self):
         parsed = avro.load(data_gen.get_schema_path('adv_schema.avsc'))
         self.assertTrue(isinstance(parsed, schema.Schema))
+
+    def test_schema_load_parse_error(self):
+        with pytest.raises(avro.ClientError) as excinfo:
+            avro.load(data_gen.get_schema_path("invalid_scema.avsc"))
+        assert 'Schema parse failed:' in str(excinfo.value)