Uncomment test commands

Author: anchitj

tests/test_Producer.py

@@ -206,8 +206,8 @@ def test_transaction_api():
     # Any subsequent APIs will fail since init did not succeed.
     with pytest.raises(KafkaException) as ex:
         p.begin_transaction()
-    assert ex.value.args[0].code() == KafkaError._STATE
-    assert ex.value.args[0].retriable() is False
+    assert ex.value.args[0].code() == KafkaError._CONFLICT
+    assert ex.value.args[0].retriable() is True
     assert ex.value.args[0].fatal() is False
     assert ex.value.args[0].txn_requires_abort() is False
 
@@ -218,22 +218,22 @@ def test_transaction_api():
     with pytest.raises(KafkaException) as ex:
         p.send_offsets_to_transaction([TopicPartition("topic", 0, 123)],
                                       group_metadata)
-    assert ex.value.args[0].code() == KafkaError._STATE
-    assert ex.value.args[0].retriable() is False
+    assert ex.value.args[0].code() == KafkaError._CONFLICT
+    assert ex.value.args[0].retriable() is True
     assert ex.value.args[0].fatal() is False
     assert ex.value.args[0].txn_requires_abort() is False
 
     with pytest.raises(KafkaException) as ex:
         p.commit_transaction(0.5)
-    assert ex.value.args[0].code() == KafkaError._STATE
-    assert ex.value.args[0].retriable() is False
+    assert ex.value.args[0].code() == KafkaError._CONFLICT
+    assert ex.value.args[0].retriable() is True
     assert ex.value.args[0].fatal() is False
     assert ex.value.args[0].txn_requires_abort() is False
 
     with pytest.raises(KafkaException) as ex:
         p.abort_transaction(0.5)
-    assert ex.value.args[0].code() == KafkaError._STATE
-    assert ex.value.args[0].retriable() is False
+    assert ex.value.args[0].code() == KafkaError._CONFLICT
+    assert ex.value.args[0].retriable() is True
     assert ex.value.args[0].fatal() is False
     assert ex.value.args[0].txn_requires_abort() is False
 

tools/wheels/build-wheels.sh

@@ -10,8 +10,8 @@ this_dir="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
 # Skip PyPy, Python2, old Python3 versions, musl, and x86 builds.
 export CIBW_SKIP="pp* cp27-* cp35-* *i686 *musllinux* $CIBW_SKIP"
 # Run a simple test suite
-#export CIBW_TEST_REQUIRES="-r tests/requirements.txt"
-#export CIBW_TEST_COMMAND="pytest {project}/tests/test_Producer.py"
+export CIBW_TEST_REQUIRES="-r tests/requirements.txt"
+export CIBW_TEST_COMMAND="pytest {project}/tests/test_Producer.py"
 
 
 librdkafka_version=$1