Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update pyro.py to import Pyro5 #1675

Draft
wants to merge 9 commits into
base: main
Choose a base branch
from
8 changes: 5 additions & 3 deletions kombu/transport/pyro.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,16 +37,18 @@
import sys
from queue import Empty, Queue

from Pyro5.compatibility import Pyro4 as pyro

from kombu.exceptions import reraise
from kombu.log import get_logger
from kombu.utils.objects import cached_property

from . import virtual

try:
import Pyro4 as pyro
from Pyro4.errors import NamingError
from Pyro4.util import SerializerBase
import Pyro5.api as pyro
from Pyro5.errors import NamingError
from Pyro5.serializers import SerializerBase
except ImportError: # pragma: no cover
pyro = NamingError = SerializerBase = None

Expand Down
Loading