nvm just needed to update tox lol

.github/workflows/python-package.yml

@@ -85,8 +85,6 @@ jobs:
           cache: pip
           cache-dependency-path: |
             requirements-dev.txt
-      - id: install-aws-cli
-        uses: unfor19/install-aws-cli-action@v1
       - name: Check Java installation
         run: source travis_java_install.sh
       - name: Pull Kafka releases
@@ -101,7 +99,6 @@ jobs:
           python -m pip install --upgrade pip
           python -m pip install tox tox-gh-actions
           pip install .
-          pip install awscli --force-reinstall --upgrade
           pip install -r requirements-dev.txt
       - name: Test with tox
         run: tox
@@ -156,8 +153,6 @@ jobs:
           cache: pip
           cache-dependency-path: |
             requirements-dev.txt
-      - id: install-aws-cli
-        uses: unfor19/install-aws-cli-action@v1
       - name: Pull Kafka releases
         run: ./build_integration.sh
         env:
@@ -171,7 +166,6 @@ jobs:
           python -m pip install --upgrade pip
           python -m pip install tox tox-gh-actions
           pip install .
-          pip install awscli --force-reinstall --upgrade
           pip install -r requirements-dev.txt
       - name: Test with tox
         run: tox

kafka/sasl/msk.py

@@ -11,9 +11,10 @@
 from kafka.protocol.types import Int32
 import kafka.errors as Errors
 
+from botocore.session import Session as BotoSession  # importing it in advance is not an option apparently...
+
 
 def try_authenticate(self, future):
-    from botocore.session import Session as BotoSession  # importing it in advance is not an option apparently...
 
     session = BotoSession()
     credentials = session.get_credentials().get_frozen_credentials()

requirements-dev.txt

@@ -15,5 +15,4 @@ Sphinx
 sphinx-rtd-theme
 tox
 xxhash
-boto3[crt]
 botocore

test/test_msk.py

@@ -1,17 +1,16 @@
 import datetime
 import json
 
-import pytest
 
 try:
     from unittest import mock
 except ImportError:
     import mock
 
+from kafka.sasl.msk import AwsMskIamClient
+
 
-@pytest.mark.skip(reason="Not yet supported")
 def client_factory(token=None):
-    from kafka.sasl.msk import AwsMskIamClient
 
     now = datetime.datetime.utcfromtimestamp(1629321911)
     with mock.patch('kafka.sasl.msk.datetime') as mock_dt:

tox.ini

@@ -28,6 +28,7 @@ deps =
     lz4
     xxhash
     crc32c
+    botocore
 commands =
     pytest {posargs:--pylint --pylint-rcfile=pylint.rc --pylint-error-types=EF --cov=kafka --cov-config=.covrc}
 setenv =