We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d642e6a commit 8151f4bCopy full SHA for 8151f4b
taskiq_faststream/broker.py
@@ -73,6 +73,8 @@ def task( # type: ignore[override]
73
SendableMessage,
74
typing.Callable[[], SendableMessage],
75
typing.Callable[[], typing.Awaitable[SendableMessage]],
76
+ typing.Callable[[], typing.Generator[SendableMessage]],
77
+ typing.Callable[[], typing.AsyncGenerator[SendableMessage]],
78
] = None,
79
*,
80
schedule: list[ScheduledTask],
0 commit comments