Add "redrive_policy" in queue config

src/qldebugger/config/file_parser.py

@@ -2,7 +2,7 @@
 from typing import Any, BinaryIO, Dict, List, NamedTuple, Optional, Tuple, Union
 
 import tomli
-from pydantic import BaseModel, Field, field_validator
+from pydantic import BaseModel, Field, PositiveInt, field_validator
 
 
 class ConfigAWS(BaseModel):
@@ -44,7 +44,13 @@ class ConfigTopic(BaseModel):
     subscribers: List[ConfigTopicSubscriber] = Field(default_factory=list)
 
 
-class ConfigQueue(BaseModel): ...
+class ConfigQueueRedrivePolicy(BaseModel):
+    dead_letter_queue: str
+    max_receive_count: PositiveInt
+
+
+class ConfigQueue(BaseModel):
+    redrive_policy: Optional[ConfigQueueRedrivePolicy] = None
 
 
 class NameHandlerTuple(NamedTuple):

tests/qldebugger/config/test_file_parser.py

@@ -12,6 +12,7 @@
     ConfigEventSourceMapping,
     ConfigLambda,
     ConfigQueue,
+    ConfigQueueRedrivePolicy,
     ConfigSecretBinary,
     ConfigSecretString,
     ConfigTopic,
@@ -71,11 +72,25 @@ def test_default_values(self) -> None:
         }
 
 
+class TestConfigQueueRedrivePolicy:
+    def test_required_fields(self) -> None:
+        required_fields = ['dead_letter_queue', 'max_receive_count']
+
+        with pytest.raises(ValidationError) as exc_info:
+            ConfigQueueRedrivePolicy.model_validate({})
+
+        assert {error['loc'] for error in exc_info.value.errors() if error['type'] == 'missing'} == {
+            (field,) for field in required_fields
+        }
+
+
 class TestConfigQueue:
-    def test_empty_object(self) -> None:
+    def test_default_values(self) -> None:
         returned = ConfigQueue()
 
-        assert returned.model_dump() == {}
+        assert returned.model_dump() == {
+            'redrive_policy': None,
+        }
 
 
 class TestNameHandlerTuple: