Находки в опенсорсе: Python

🚀 New issue to ag2ai/faststream by @aleksandrtikhonov
📝 Bug: missing error logs when broker initialize with argument log_level=logging.DEBUG (#2585)

Describe the bug
Missing ERROR logs when broker initialize with argument log_level=logging.DEBUG

How to reproduce
Include source code:

from faststream import FastStream
from faststream.confluent import KafkaBroker, KafkaRouter
from pydantic import BaseModel

broker = KafkaBroker("localhost:9092", log_level=logging.DEBUG)
router = KafkaRouter()
broker.include_router(router)
app = FastStream(broker)


class Suka(BaseModel):
    suka_id: int


@router.subscriber("test")
async def suking(suka: Suka) -> None:
    print(suka)

1. Send a message to a topic that does not match the expected model Suka.

Expected behavior
See error logs(error pydantic serializtion) in the console

Observed behavior
Error logs are missing.

Environment
faststream-0.6.0

Additional context
Provide any other relevant context or information about the problem here.

#good_first_issue #bug

sent via relator

😁12🗿3🌚2

www.tgoop.com/opensource_findings_python/135

515 viewsgh-issuer-bot, Oct 15 at 16:47

🚀 New issue to ag2ai/faststream by @aleksandrtikhonov
📝 Bug: missing error logs when broker initialize with argument log_level=logging.DEBUG (#2585)

Describe the bug
Missing ERROR logs when broker initialize with argument log_level=logging.DEBUG

How to reproduce
Include source code:

from faststream import FastStream
from faststream.confluent import KafkaBroker, KafkaRouter
from pydantic import BaseModel

broker = KafkaBroker("localhost:9092", log_level=logging.DEBUG)
router = KafkaRouter()
broker.include_router(router)
app = FastStream(broker)


class Suka(BaseModel):
    suka_id: int


@router.subscriber("test")
async def suking(suka: Suka) -> None:
    print(suka)

BY Находки в опенсорсе: Python