Updated Dict typing

esgf-consumer/esgf_consumer/items.py

@@ -67,7 +67,7 @@ async def hard_delete_item(
 
 async def partial_update_item(
     collection_id: str,
-    item: dict,
+    item: Dict[str, Any],
     item_id: str,
     settings: Settings,
     client: httpx.AsyncClient,

esgf-generator/esgf_generator/cli.py

@@ -1,7 +1,7 @@
 import json
 import random
 import time
-from typing import Literal
+from typing import Dict, Literal
 
 import click
 import httpx

esgf-transaction-api/esgf_transaction_api/main.py

@@ -127,7 +127,9 @@ async def revoke_item_hard(collection_id: str, item_id: str) -> None:
     await alternate_message(event)
 
 
-async def partial_update_item(collection_id: str, item_id: str, item: dict) -> None:
+async def partial_update_item(
+    collection_id: str, item_id: str, item: Dict[str, Any]
+) -> None:
     payload = PartialUpdatePayload(
         method="PATCH", collection_id=collection_id, item=item, item_id=item_id
     )
@@ -205,7 +207,9 @@ async def delete_item_hard(item_id: str, collection_id: str) -> None:
 
 
 @app.patch("/{collection_id}/items/{item_id}")
-async def partial_update(item_id: str, collection_id: str, item: dict) -> None:
+async def partial_update(
+    item_id: str, collection_id: str, item: Dict[str, Any]
+) -> None:
     """Add Update message to kafka event stream.
 
     Args: