Remove rpc prefix

ghga-de · Aug 1, 2024 · 0d670cc · 0d670cc
1 parent 466b846
commit 0d670cc
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 19 deletions.
diff --git a/tests/test_consumer.py b/tests/test_consumer.py
@@ -42,17 +42,14 @@ async def test_resource_upsert(
     assert results_all.count > 0
 
     # define content of resource
-    content = {
+    content: dict = {
         "has_object": {"type": "added-resource-object", "id": "98u44-f4jo4"},
         "field1": "something",
         "category": "test object",
     }
 
     # define a resource to be upserted
-    resource = models.Resource(
-        id_=resource_id,
-        content=content,  # type: ignore
-    )
+    resource = models.Resource(id_=resource_id, content=content)
 
     # put together event payload
     payload = event_schemas.SearchableResource(
@@ -82,11 +79,9 @@ async def test_resource_upsert(
         assert updated_resources.count == results_all.count
 
     # remove unselected fields
-    content = resource.content
-    assert isinstance(content, dict)
+    content = resource.content  # type: ignore
     del content["field1"]
     del content["category"]
-    assert isinstance(content["has_object"], dict)
     del content["has_object"]["id"]
 
     assert resource in updated_resources.hits

diff --git a/tests/test_resources.py b/tests/test_resources.py
@@ -147,15 +147,14 @@ async def test_resource_load(joint_fixture: JointFixture):
         class_name="DatasetEmbedded", query="", filters=[]
     )
 
+    content: dict = {
+        "has_object": {"type": "added-resource-object", "id": "98u44-f4jo4"},
+        "field1": "something",
+        "category": "test object",
+    }
+
     # define and load a new resource
-    resource = models.Resource(
-        id_="added-resource",
-        content={
-            "has_object": {"type": "added-resource-object", "id": "98u44-f4jo4"},
-            "field1": "something",
-            "category": "test object",
-        },
-    )
+    resource = models.Resource(id_="added-resource", content=content)
 
     await joint_fixture.query_handler.load_resource(
         resource=resource, class_name="DatasetEmbedded"
@@ -179,11 +178,9 @@ async def test_resource_load(joint_fixture: JointFixture):
     assert validated_resource.id_ == resource.id_
 
     # remove unselected fields
-    content = resource.content
-    assert isinstance(content, dict)
+    content = resource.content  # type: ignore
     del content["field1"]
     del content["category"]
-    assert isinstance(content["has_object"], dict)
     del content["has_object"]["id"]
 
     assert validated_resource.content == content