diff --git a/taskiq_redis/redis_broker.py b/taskiq_redis/redis_broker.py index 7253fb6..eaf309b 100644 --- a/taskiq_redis/redis_broker.py +++ b/taskiq_redis/redis_broker.py @@ -16,7 +16,7 @@ class BaseRedisBroker(AsyncBroker): def __init__( self, - url: Optional[str] = None, + url: str, task_id_generator: Optional[Callable[[], str]] = None, result_backend: Optional[AsyncResultBackend[_T]] = None, queue_name: str = "taskiq", diff --git a/tests/test_broker.py b/tests/test_broker.py index 62a9779..af731bd 100644 --- a/tests/test_broker.py +++ b/tests/test_broker.py @@ -8,6 +8,12 @@ from taskiq_redis import ListQueueBroker, PubSubBroker +def test_no_url_should_raise_typeerror() -> None: + """Test that url is expected.""" + with pytest.raises(TypeError): + ListQueueBroker() # type: ignore + + async def get_message( # type: ignore broker: AsyncBroker, ) -> Union[bytes, AckableMessage]: