Merge pull request #34 from infn-datacloud/fed-reg-v1.0.0-beta.2

Bump fed-reg from v1.0.0-beta.1 to v1.0.0-beta.2

pyproject.toml

@@ -9,7 +9,7 @@ packages = [{ include = "src" }]
 python = ">=3.9,<4.0.0"
 python-openstackclient = "^6.2.0"
 python-glanceclient = "^4.4.0"
-federation-registry = {git = "https://github.com/infn-datacloud/federation-registry.git", tag = "v1.0.0-beta.1"}
+federation-registry = {git = "https://github.com/infn-datacloud/federation-registry.git", tag = "v1.0.0-beta.2"}
 liboidcagent = "^0.6" # {git = "https://github.com/giosava94/liboidc-agent-py.git", branch = "local-and-remote" }
 kafka-python = "^2.0.2"
 

tests/test_kafka.py

@@ -1,4 +1,3 @@
-import json
 from logging import getLogger
 from unittest.mock import Mock, patch
 
@@ -165,20 +164,18 @@ def test_send_messages(
     send_kafka_messages(kafka_prod=mock_prod, connections_data=[{**connection_data}])
 
     mock_prod.send.assert_called_with(
-        json.dumps(
-            {
-                "msg_version": "1.0.0",
-                "provider_name": connection_data["provider_conf"]["name"],
-                "provider_type": connection_data["provider_conf"]["type"],
-                "region_name": connection_data["provider_conf"]["regions"][0]["name"],
-                "issuer_endpoint": connection_data["issuer"]["endpoint"],
-                "user_group": connection_data["issuer"]["user_groups"][0]["name"],
-                "project_id": connection_data["project"]["uuid"],
-                "block_storage_services": connection_data["block_storage_services"],
-                "compute_services": connection_data["compute_services"],
-                "identity_services": connection_data["identity_services"],
-                "network_services": connection_data["network_services"],
-                "object_store_services": connection_data["object_store_services"],
-            }
-        )
+        {
+            "msg_version": "1.0.0",
+            "provider_name": connection_data["provider_conf"]["name"],
+            "provider_type": connection_data["provider_conf"]["type"],
+            "region_name": connection_data["provider_conf"]["regions"][0]["name"],
+            "issuer_endpoint": connection_data["issuer"]["endpoint"],
+            "user_group": connection_data["issuer"]["user_groups"][0]["name"],
+            "project_id": connection_data["project"]["uuid"],
+            "block_storage_services": connection_data["block_storage_services"],
+            "compute_services": connection_data["compute_services"],
+            "identity_services": connection_data["identity_services"],
+            "network_services": connection_data["network_services"],
+            "object_store_services": connection_data["object_store_services"],
+        }
     )