You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
To suggest an idea or inquire about a new Message Broker supporting feature or any other enhancement, please follow this template:
Is your feature request related to a problem? Please describe.
I'm not sure if it's problem related. Maybe it's already there, but not described as I see in docs.
Describe the solution you'd like
To test some tasks, I'd like to restart each worker once it finishes processing.
Feature code example
fromfaststream.nats.fastapiimportNatsRouterrouter=NatsRouter("nats://nats-service")
@router.subscriber("subject", "queue", max_msgs=1)asyncdefworker():
# auto restart after max_msgs reach 1# or manually restartifTrue:
restart()
...
Describe alternatives you've considered
Provide a clear and concise description of any alternative solutions or features you've thought about.
Additional context
Include any other relevant context or screenshots related to the feature request.
The text was updated successfully, but these errors were encountered:
To suggest an idea or inquire about a new Message Broker supporting feature or any other enhancement, please follow this template:
Is your feature request related to a problem? Please describe.
I'm not sure if it's problem related. Maybe it's already there, but not described as I see in docs.
Describe the solution you'd like
To test some tasks, I'd like to restart each worker once it finishes processing.
Feature code example
Describe alternatives you've considered
Provide a clear and concise description of any alternative solutions or features you've thought about.
Additional context
Include any other relevant context or screenshots related to the feature request.
The text was updated successfully, but these errors were encountered: