Fixed an invalid argument configuration (#2099)

* Fixed an invalid argument configuration

* Applied sync conversion tool for parallel code

Author: MSeal

src/confluent_kafka/schema_registry/_async/schema_registry_client.py

@@ -667,7 +667,13 @@ async def register_schema_full_response(
         if schema_id is not None:
             result = self._cache.get_schema_by_id(subject_name, schema_id)
             if result is not None:
-                return RegisteredSchema(schema_id, result[0], result[1], subject_name, None)
+                return RegisteredSchema(
+                    schema_id=schema_id,
+                    guid=result[0],
+                    subject=subject_name,
+                    version=None,
+                    schema=result[1]
+                )
 
         request = schema.to_dict()
 
@@ -682,7 +688,7 @@ async def register_schema_full_response(
             guid=result.guid,
             subject=result.subject or subject_name,
             version=result.version,
-            schema=result.schema,
+            schema=result.schema
         )
 
         # The registered schema may not be fully populated

src/confluent_kafka/schema_registry/_sync/schema_registry_client.py

@@ -667,7 +667,13 @@ def register_schema_full_response(
         if schema_id is not None:
             result = self._cache.get_schema_by_id(subject_name, schema_id)
             if result is not None:
-                return RegisteredSchema(schema_id, result[0], result[1], subject_name, None)
+                return RegisteredSchema(
+                    schema_id=schema_id,
+                    guid=result[0],
+                    subject=subject_name,
+                    version=None,
+                    schema=result[1]
+                )
 
         request = schema.to_dict()
 
@@ -682,7 +688,7 @@ def register_schema_full_response(
             guid=result.guid,
             subject=result.subject or subject_name,
             version=result.version,
-            schema=result.schema,
+            schema=result.schema
         )
 
         # The registered schema may not be fully populated

tests/schema_registry/_async/test_api_client.py

@@ -87,6 +87,17 @@ async def test_register_schema(mock_schema_registry, load_avsc):
     assert result == SCHEMA_ID
 
 
+async def test_register_schema_full_response_recall(mock_schema_registry, load_avsc):
+    conf = {'url': TEST_URL}
+    sr = AsyncSchemaRegistryClient(conf)
+    schema = Schema(load_avsc('basic_schema.avsc'), schema_type='AVRO')
+
+    await sr.register_schema('test-key', schema)
+
+    result = await sr.register_schema_full_response('test-key', schema)
+    assert result.schema_id == SCHEMA_ID
+
+
 async def test_register_schema_incompatible(mock_schema_registry, load_avsc):
     conf = {'url': TEST_URL}
     sr = AsyncSchemaRegistryClient(conf)

tests/schema_registry/_sync/test_api_client.py

@@ -87,6 +87,17 @@ def test_register_schema(mock_schema_registry, load_avsc):
     assert result == SCHEMA_ID
 
 
+def test_register_schema_full_response_recall(mock_schema_registry, load_avsc):
+    conf = {'url': TEST_URL}
+    sr = SchemaRegistryClient(conf)
+    schema = Schema(load_avsc('basic_schema.avsc'), schema_type='AVRO')
+
+    sr.register_schema('test-key', schema)
+
+    result = sr.register_schema_full_response('test-key', schema)
+    assert result.schema_id == SCHEMA_ID
+
+
 def test_register_schema_incompatible(mock_schema_registry, load_avsc):
     conf = {'url': TEST_URL}
     sr = SchemaRegistryClient(conf)