ALT Linux Bugzilla
– Attachment 18308 Details for
Bug 54037
faststream - не работает брокер Redis
New bug
|
Search
|
[?]
|
Help
Register
|
Log In
[x]
|
Forgot Password
Login:
[x]
|
EN
|
RU
лог с ошибкой с версией из репозитория
error.log (text/x-log), 55.86 KB, created by
Руслан Вишталмагомедов
on 2025-04-28 13:33:32 MSK
(
hide
)
Description:
лог с ошибкой с версией из репозитория
Filename:
MIME Type:
Creator:
Руслан Вишталмагомедов
Created:
2025-04-28 13:33:32 MSK
Size:
55.86 KB
patch
obsolete
>2025-04-28 13:31:44,815 [32mINFO[0m - FastStream app starting... >ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ Traceback (most recent call last) âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ® >â /usr/lib/python3/site-packages/faststream/cli/main.py:172 in run â >â â >â 169 â â â ) âââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââ® â >â 170 â â app = 'test:app' â â >â 171 â else: â app_dir = '.' â â >â â± 172 â â _run_imported_app( â app_obj = <faststream.app.FastStream object at 0x7f0d5be1fda0> â â >â 173 â â â app_obj, â args = ('test:app', {}, False, 0) â â >â 174 â â â extra_options=extra, â casted_log_level = 0 â â >â 175 â â â log_level=casted_log_level, â ctx = <click.core.Context object at 0x7f0d5bf72390> â â >â â extra = {} â â >â â is_factory = False â â >â â log_level = <LogLevels.notset: 'notset'> â â >â â module_path = PosixPath('/home/test/test') â â >â â reload = False â â >â â watch_extensions = [] â â >â â workers = 1 â â >â â°âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/faststream/cli/main.py:218 in _run_imported_app â >â â >â 215 â â â uvloop.install() ââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââ® â >â 216 â â app_level = 20 â â >â 217 â try: â app_obj = <faststream.app.FastStream object at 0x7f0d5be1fda0> â â >â â± 218 â â anyio.run( â extra_options = {} â â >â 219 â â â app_obj.run, â log_level = 0 â â >â 220 â â â app_level, â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â 221 â â â extra_options, â >â â >â /usr/lib/python3/site-packages/anyio/_core/_eventloop.py:74 in run â >â â >â 71 â â >â 72 â try: â >â 73 â â backend_options = backend_options or {} â >â â± 74 â â return async_backend.run(func, args, {}, backend_options) â >â 75 â finally: â >â 76 â â if token: â >â 77 â â â sniffio.current_async_library_cvar.reset(token) â >â â >â âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ locals âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â args = (20, {}) â â >â â backend = 'asyncio' â â >â â backend_options = {} â â >â â func = <bound method FastStream.run of <faststream.app.FastStream object at 0x7f0d5be1fda0>> â â >â â token = <Token used var=<ContextVar name='current_async_library_cvar' default=None at 0x7f0d5dd36890> at 0x7f0d5bb63540> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2310 in run â >â â >â 2307 â â â loop_factory = uvloop.new_event_loop â >â 2308 â â â >â 2309 â â with Runner(debug=debug, loop_factory=loop_factory) as runner: â >â â± 2310 â â â return runner.run(wrapper()) â >â 2311 â â >â 2312 â @classmethod â >â 2313 â def current_token(cls) -> object: â >â â >â ââââââââââââââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â args = (20, {}) â â >â â debug = None â â >â â func = <bound method FastStream.run of <faststream.app.FastStream object at 0x7f0d5be1fda0>> â â >â â kwargs = {} â â >â â loop_factory = None â â >â â options = {} â â >â â runner = <asyncio.runners.Runner object at 0x7f0d5bc07e60> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib64/python3.12/asyncio/runners.py:118 in run â >â â >â 115 â â â >â 116 â â self._interrupt_count = 0 â >â 117 â â try: â >â â± 118 â â â return self._loop.run_until_complete(task) â >â 119 â â except exceptions.CancelledError: â >â 120 â â â if self._interrupt_count > 0: â >â 121 â â â â uncancel = getattr(task, "uncancel", None) â >â â >â ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â context = <_contextvars.Context object at 0x7f0d5bc4b200> â â >â â coro = <coroutine object FastStream.run at 0x7f0d5ba182e0> â â >â â self = <asyncio.runners.Runner object at 0x7f0d5bc07e60> â â >â â sigint_handler = functools.partial(<bound method Runner._on_sigint of <asyncio.runners.Runner object at 0x7f0d5bc07e60>>, main_task=<Task finished name='faststream.app.FastStream.run' â â >â â coro=<FastStream.run() done, defined at /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2291> exception=AttributeError("type object 'Redis' has no attribute â â >â â 'from_pool'")>) â â >â â task = <Task finished name='faststream.app.FastStream.run' coro=<FastStream.run() done, defined at /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2291> â â >â â exception=AttributeError("type object 'Redis' has no attribute 'from_pool'")> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib64/python3.12/asyncio/base_events.py:691 in run_until_complete â >â â >â 688 â â if not future.done(): â >â 689 â â â raise RuntimeError('Event loop stopped before Future completed.') â >â 690 â â â >â â± 691 â â return future.result() â >â 692 â â >â 693 â def stop(self): â >â 694 â â """Stop running the event loop. â >â â >â ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â future = <Task finished name='faststream.app.FastStream.run' coro=<FastStream.run() done, defined at /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2291> â â >â â exception=AttributeError("type object 'Redis' has no attribute 'from_pool'")> â â >â â new_task = False â â >â â self = <_UnixSelectorEventLoop running=False closed=True debug=False> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2298 in wrapper â >â â >â 2295 â â â _task_states[task] = TaskState(None, None) â >â 2296 â â â â >â 2297 â â â try: â >â â± 2298 â â â â return await func(*args) â >â 2299 â â â finally: â >â 2300 â â â â del _task_states[task] â >â 2301 â >â â >â ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â args = (20, {}) â â >â â func = <bound method FastStream.run of <faststream.app.FastStream object at 0x7f0d5be1fda0>> â â >â â task = <Task finished name='faststream.app.FastStream.run' coro=<FastStream.run() done, defined at /usr/lib/python3/site-packages/anyio/_backends/_asyncio.py:2291> â â >â â exception=AttributeError("type object 'Redis' has no attribute 'from_pool'")> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/faststream/app.py:53 in run â >â â >â 50 â â â â â tg.cancel_scope.cancel() âââââââââââââââââââââââââââââââââââââââââ locals âââââââââââââââââââââââââââââââââââââââââ® â >â 51 â â â except ExceptionGroup as e: â ex = AttributeError("type object 'Redis' has no attribute 'from_pool'") â â >â 52 â â â â for ex in e.exceptions: â log_level = 20 â â >â â± 53 â â â â â raise ex from None â run_extra_options = {} â â >â 54 â â self = <faststream.app.FastStream object at 0x7f0d5be1fda0> â â >â 55 â def as_asgi( â sleep_time = 0.1 â â >â 56 â â self, â tg = <anyio._backends._asyncio.TaskGroup object at 0x7f0d5bc081a0> â â >â â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/faststream/_internal/application.py:199 in _startup â >â â >â 196 â â run_extra_options: Optional[Dict[str, "SettingField"]] = None, ââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââ® â >â 197 â ) -> None: â log_level = 20 â â >â 198 â â self._log(log_level, "FastStream app starting...") â run_extra_options = {} â â >â â± 199 â â await self.start(**(run_extra_options or {})) â self = <faststream.app.FastStream object at 0x7f0d5be1fda0> â â >â 200 â â assert self.broker, "You should setup a broker" # nosec B101 â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â 201 â â self._log( â >â 202 â â â log_level, "FastStream app started successfully! To exit, press CTRL+C" â >â â >â /usr/lib/python3/site-packages/faststream/_internal/application.py:177 in start â >â â >â 174 â â â await func(**run_extra_options) ââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââ® â >â 175 â â â run_extra_options = {} â â >â 176 â â if self.broker is not None: â self = <faststream.app.FastStream object at 0x7f0d5be1fda0> â â >â â± 177 â â â await self.broker.start() â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â 178 â â â >â 179 â â for func in self._after_startup_calling: â >â 180 â â â await func() â >â â >â /usr/lib/python3/site-packages/faststream/redis/broker/broker.py:351 in start â >â â >â 348 â â await super()._close(exc_type, exc_val, exc_tb) ââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââ® â >â 349 â â self = <faststream.redis.broker.broker.RedisBroker object at 0x7f0d5bedebd0> â â >â 350 â async def start(self) -> None: â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â± 351 â â await super().start() â >â 352 â â â >â 353 â â for handler in self._subscribers.values(): â >â 354 â â â self._log( â >â â >â /usr/lib/python3/site-packages/faststream/broker/core/usecase.py:219 in start â >â â >â 216 â async def start(self) -> None: ââââââââââââââââââââââââââââââââââââ locals ââââââââââââââââââââââââââââââââââââ® â >â 217 â â """Start the broker async use case.""" â self = <faststream.redis.broker.broker.RedisBroker object at 0x7f0d5bedebd0> â â >â 218 â â self._abc_start() â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â± 219 â â await self.connect() â >â 220 â â >â 221 â async def connect(self, **kwargs: Any) -> ConnectionType: â >â 222 â â """Connect to a remote server.""" â >â â >â /usr/lib/python3/site-packages/faststream/redis/broker/broker.py:269 in connect â >â â >â 266 â â else: âââââââââââââââââââââââââââââââââââââââââ locals âââââââââââââââââââââââââââââââââââââââââ® â >â 267 â â â connect_kwargs = dict(kwargs).copy() â connect_kwargs = {} â â >â 268 â â â kwargs = {} â â >â â± 269 â â return await super().connect(**connect_kwargs) â self = <faststream.redis.broker.broker.RedisBroker object at 0x7f0d5bedebd0> â â >â 270 â â url = EMPTY â â >â 271 â @override â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â 272 â async def _connect( # type: ignore[override] â >â â >â /usr/lib/python3/site-packages/faststream/broker/core/usecase.py:226 in connect â >â â >â 223 â â if self._connection is None: ââââââââââââââââââââââââââââââââââââââââââ locals âââââââââââââââââââââââââââââââââââââââââââ® â >â 224 â â â connection_kwargs = self._connection_kwargs.copy() â connection_kwargs = { â â >â 225 â â â connection_kwargs.update(kwargs) â â 'url': 'redis://localhost:6379', â â >â â± 226 â â â self._connection = await self._connect(**connection_kwargs) â â 'host': EMPTY, â â >â 227 â â self.setup() â â 'port': EMPTY, â â >â 228 â â return self._connection â â 'db': EMPTY, â â >â 229 â â 'client_name': None, â â >â â â 'health_check_interval': 0, â â >â â â 'max_connections': None, â â >â â â 'socket_timeout': None, â â >â â â 'socket_connect_timeout': None, â â >â â â 'socket_read_size': 65536, â â >â â â ... +10 â â >â â } â â >â â kwargs = {} â â >â â self = <faststream.redis.broker.broker.RedisBroker object at 0x7f0d5bedebd0> â â >â â°âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â â >â /usr/lib/python3/site-packages/faststream/redis/broker/broker.py:331 in _connect â >â â >â 328 â â â lib_version=__version__, â >â 329 â â ) â >â 330 â â â >â â± 331 â â client: Redis[bytes] = Redis.from_pool(pool) # type: ignore[attr-defined] â >â 332 â â self._producer = RedisFastProducer( â >â 333 â â â connection=client, â >â 334 â â â parser=self._parser, â >â â >â ââââââââââââââââââââââââââââââââââââââââââââââââââââ locals âââââââââââââââââââââââââââââââââââââââââââââââââââââ® â >â â client_name = None â â >â â connection_class = EMPTY â â >â â db = EMPTY â â >â â decode_responses = False â â >â â encoding = 'utf-8' â â >â â encoding_errors = 'strict' â â >â â health_check_interval = 0 â â >â â host = EMPTY â â >â â max_connections = None â â >â â pool = <repr-error "Connection.__init__() got an unexpected keyword argument 'lib_name'"> â â >â â port = EMPTY â â >â â retry_on_timeout = False â â >â â self = <faststream.redis.broker.broker.RedisBroker object at 0x7f0d5bedebd0> â â >â â socket_connect_timeout = None â â >â â socket_keepalive = False â â >â â socket_keepalive_options = None â â >â â socket_read_size = 65536 â â >â â socket_timeout = None â â >â â socket_type = 0 â â >â â url = 'redis://localhost:6379' â â >â â url_options = { â â >â â â 'host': 'localhost', â â >â â â 'port': 6379, â â >â â â 'client_name': None, â â >â â â 'health_check_interval': 0, â â >â â â 'max_connections': None, â â >â â â 'socket_timeout': None, â â >â â â 'socket_connect_timeout': None, â â >â â â 'socket_read_size': 65536, â â >â â â 'socket_keepalive': False, â â >â â â 'socket_keepalive_options': None, â â >â â â ... +7 â â >â â } â â >â â°âââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠â >â°ââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââââ⯠>AttributeError: type object 'Redis' has no attribute 'from_pool'
<b>You cannot view the attachment while viewing its details because your browser does not support IFRAMEs. <a href="attachment.cgi?id=18308">View the attachment on a separate page</a>.</b>
View Attachment As Raw
Actions:
View
Attachments on
bug 54037
: 18308
