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):
16
16
17
17
def __init__ (
18
18
self ,
19
- url : Optional [ str ] = None ,
19
+ url : str ,
20
20
task_id_generator : Optional [Callable [[], str ]] = None ,
21
21
result_backend : Optional [AsyncResultBackend [_T ]] = None ,
22
22
queue_name : str = "taskiq" ,
Original file line number Diff line number Diff line change 8
8
from taskiq_redis import ListQueueBroker , PubSubBroker
9
9
10
10
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
+
11
21
async def get_message ( # type: ignore
12
22
broker : AsyncBroker ,
13
23
) -> Union [bytes , AckableMessage ]:
You can’t perform that action at this time.
0 commit comments