Merge pull request #40 from igoose1/39-explicit-url

Author: s3rius

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",

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]: