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

Feature: endless asyncio tasks hypervisor #1656

Open
2 tasks
Lancetnik opened this issue Aug 8, 2024 · 0 comments
Open
2 tasks

Feature: endless asyncio tasks hypervisor #1656

Lancetnik opened this issue Aug 8, 2024 · 0 comments
Labels
AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module enhancement New feature or request good first issue Good for newcomers NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features

Comments

@Lancetnik
Copy link
Member

Now we have some endless asyncio.Tasks consuming messages like here or in kafka/confluent/redis as well.

They have no chance to fail, but anything can sometimes things happens and users even don't see any exception about it. Thus, we should log this tasks failure and try to restart them.

  • pass broker.logger to subscriber through setup method
  • add task done callback to log an exception and restart it

It should helps users to diagnostic the problem and create Issue about accident and improve the system susteinability

@Lancetnik Lancetnik added enhancement New feature or request good first issue Good for newcomers Confluent Issues related to `faststream.confluent` module AioKafka Issues related to `faststream.kafka` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features labels Aug 8, 2024
@Lancetnik Lancetnik changed the title Feature: endless asyncio tasks hupervisor Feature: endless asyncio tasks hypervisor Aug 15, 2024
@Lancetnik Lancetnik mentioned this issue Sep 10, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module enhancement New feature or request good first issue Good for newcomers NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
Projects
Status: Backlog
Development

No branches or pull requests

1 participant