File tree Expand file tree Collapse file tree 2 files changed +11
-1
lines changed Expand file tree Collapse file tree 2 files changed +11
-1
lines changed Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ class BaseRedisBroker(AsyncBroker):
1616
1717 def __init__ (
1818 self ,
19- url : Optional [ str ] = None ,
19+ url : str ,
2020 task_id_generator : Optional [Callable [[], str ]] = None ,
2121 result_backend : Optional [AsyncResultBackend [_T ]] = None ,
2222 queue_name : str = "taskiq" ,
Original file line number Diff line number Diff line change 88from taskiq_redis import ListQueueBroker , PubSubBroker
99
1010
11+ def test_no_url_should_raise_typeerror () -> None :
12+ """Test that url is expected."""
13+ with pytest .raises (TypeError ):
14+ ListQueueBroker () # type: ignore
15+
16+ with pytest .raises (TypeError ):
17+ # it's `url`, not `redis_url`
18+ ListQueueBroker (redis_url = "redis://localhost/0" ) # type: ignore
19+
20+
1121async def get_message ( # type: ignore
1222 broker : AsyncBroker ,
1323) -> Union [bytes , AckableMessage ]:
You can’t perform that action at this time.
0 commit comments