Resolving TypeError, during version unpacking

[couzhei]

This will make sure that the version unpacking doesn't stop connection to some versions of message brokers. For message brokers with normal-style version, say 3.13.6,

def version_string_as_tuple(s: str) -> version_info_t:
    """Convert version string to version info tuple."""
    v = _unpack_version(*s.split('.'))
    ...

will result in ['3', '13', '6'] list. But for newer releases of rabbitmq, say when you pull docker image using a specified version, in my case 4.0-rc as discussed in this issue related to #2088 it becomes this:

['4', '0', '0+beta', '2', '6', 'g65c3daf']

which causes that TypeError.

[Nusnus]

Thank you for the PR.

Please add tests and fix the lint error.

[couzhei]

I really don't get the CI error. I even created a virtual environment from a 3.9 version, but it was okay there. I also have this test, almost always failed:

===================================================== short test summary info =====================================================
FAILED t/unit/transport/test_redis.py::test_Redis::test_publish__consume - OSError: [Errno 9] Bad file descriptor

Results (37.34s):
    1181 passed
       1 failed
         - t/unit/transport/test_redis.py:1373 test_Redis.test_publish__consume
     315 skipped
Restoring 2 unacknowledged message(s)

Which I'm not sure why it happens when I run tests locally.

[auvipy]

re run the job to see

[auvipy]

we just need to fix the lint error

[couzhei]

Thank you, my bad. I have never used pydocstyle, but I have just checked it out, and will be aware of it in the future.

[couzhei]

re run the job to see

I think I don't have the right to re-run a job.

[SandeepaDevin]

/python3.9/site-packages/kombu/transport/redis.py

GlobalKeyPrefixMixin | <class 'kombu.transport.redis.GlobalKeyPrefixMixin'>
InconsistencyError | <class 'kombu.exceptions.InconsistencyError'>
Mutex | <function Mutex at 0x7f1e4ee5eb80>
MutexHeld | <class 'kombu.transport.redis.MutexHeld'>
PRIORITY_STEPS | [0, 3, 6, 9]
READ | 1
VersionMismatch | <class 'kombu.exceptions.VersionMismatch'>
poll | <function poll at 0x7f1e4eeae3a0>
promise | <class 'vine.promises.promise'>
redis | None
register_after_fork | <function register_after_fork at 0x7f1e51c95f70>

I tried from supervisor and it seems like it cannot pick the redis version.