Minor workaround for PyCharm syntax checker (#1988)

Author: rayokota

src/confluent_kafka/schema_registry/_async/avro.py

@@ -184,7 +184,7 @@ class AsyncAvroSerializer(AsyncBaseSerializer):
                      'subject.name.strategy': topic_subject_name_strategy,
                      'schema.id.serializer': prefix_schema_id_serializer}
 
-    async def __init__(
+    async def __init_impl(
         self,
         schema_registry_client: AsyncSchemaRegistryClient,
         schema_str: Union[str, Schema, None] = None,
@@ -282,6 +282,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, obj: object, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(obj, ctx)
 
@@ -436,7 +438,7 @@ class AsyncAvroDeserializer(AsyncBaseDeserializer):
                      'subject.name.strategy': topic_subject_name_strategy,
                      'schema.id.deserializer': dual_schema_id_deserializer}
 
-    async def __init__(
+    async def __init_impl(
         self,
         schema_registry_client: AsyncSchemaRegistryClient,
         schema_str: Union[str, Schema, None] = None,
@@ -505,6 +507,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Union[dict, object, None]:
         return self.__deserialize(data, ctx)
 

src/confluent_kafka/schema_registry/_async/json_schema.py

@@ -201,7 +201,7 @@ class AsyncJSONSerializer(AsyncBaseSerializer):
                      'schema.id.serializer': prefix_schema_id_serializer,
                      'validate': True}
 
-    async def __init__(
+    async def __init_impl(
         self,
         schema_str: Union[str, Schema, None],
         schema_registry_client: AsyncSchemaRegistryClient,
@@ -293,6 +293,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, obj: object, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(obj, ctx)
 
@@ -468,7 +470,7 @@ class AsyncJSONDeserializer(AsyncBaseDeserializer):
                      'schema.id.deserializer': dual_schema_id_deserializer,
                      'validate': True}
 
-    async def __init__(
+    async def __init_impl(
         self,
         schema_str: Union[str, Schema, None],
         from_dict: Optional[Callable[[dict, SerializationContext], object]] = None,
@@ -547,6 +549,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(data, ctx)
 

src/confluent_kafka/schema_registry/_async/protobuf.py

@@ -201,7 +201,7 @@ class AsyncProtobufSerializer(AsyncBaseSerializer):
         'use.deprecated.format': False,
     }
 
-    async def __init__(
+    async def __init_impl(
         self,
         msg_type: Message,
         schema_registry_client: AsyncSchemaRegistryClient,
@@ -282,6 +282,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     @staticmethod
     def _write_varint(buf: io.BytesIO, val: int, zigzag: bool = True):
         """
@@ -495,7 +497,7 @@ class AsyncProtobufDeserializer(AsyncBaseDeserializer):
         'use.deprecated.format': False,
     }
 
-    async def __init__(
+    async def __init_impl(
         self,
         message_type: Message,
         conf: Optional[dict] = None,
@@ -544,6 +546,8 @@ async def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(data, ctx)
 

src/confluent_kafka/schema_registry/_sync/avro.py

@@ -184,7 +184,7 @@ class AvroSerializer(BaseSerializer):
                      'subject.name.strategy': topic_subject_name_strategy,
                      'schema.id.serializer': prefix_schema_id_serializer}
 
-    def __init__(
+    def __init_impl(
         self,
         schema_registry_client: SchemaRegistryClient,
         schema_str: Union[str, Schema, None] = None,
@@ -282,6 +282,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, obj: object, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(obj, ctx)
 
@@ -436,7 +438,7 @@ class AvroDeserializer(BaseDeserializer):
                      'subject.name.strategy': topic_subject_name_strategy,
                      'schema.id.deserializer': dual_schema_id_deserializer}
 
-    def __init__(
+    def __init_impl(
         self,
         schema_registry_client: SchemaRegistryClient,
         schema_str: Union[str, Schema, None] = None,
@@ -505,6 +507,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Union[dict, object, None]:
         return self.__deserialize(data, ctx)
 

src/confluent_kafka/schema_registry/_sync/json_schema.py

@@ -201,7 +201,7 @@ class JSONSerializer(BaseSerializer):
                      'schema.id.serializer': prefix_schema_id_serializer,
                      'validate': True}
 
-    def __init__(
+    def __init_impl(
         self,
         schema_str: Union[str, Schema, None],
         schema_registry_client: SchemaRegistryClient,
@@ -293,6 +293,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, obj: object, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(obj, ctx)
 
@@ -468,7 +470,7 @@ class JSONDeserializer(BaseDeserializer):
                      'schema.id.deserializer': dual_schema_id_deserializer,
                      'validate': True}
 
-    def __init__(
+    def __init_impl(
         self,
         schema_str: Union[str, Schema, None],
         from_dict: Optional[Callable[[dict, SerializationContext], object]] = None,
@@ -547,6 +549,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(data, ctx)
 

src/confluent_kafka/schema_registry/_sync/protobuf.py

@@ -201,7 +201,7 @@ class ProtobufSerializer(BaseSerializer):
         'use.deprecated.format': False,
     }
 
-    def __init__(
+    def __init_impl(
         self,
         msg_type: Message,
         schema_registry_client: SchemaRegistryClient,
@@ -282,6 +282,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     @staticmethod
     def _write_varint(buf: io.BytesIO, val: int, zigzag: bool = True):
         """
@@ -495,7 +497,7 @@ class ProtobufDeserializer(BaseDeserializer):
         'use.deprecated.format': False,
     }
 
-    def __init__(
+    def __init_impl(
         self,
         message_type: Message,
         conf: Optional[dict] = None,
@@ -544,6 +546,8 @@ def __init__(
             rule.configure(self._registry.config() if self._registry else {},
                            rule_conf if rule_conf else {})
 
+    __init__ = __init_impl
+
     def __call__(self, data: bytes, ctx: Optional[SerializationContext] = None) -> Optional[bytes]:
         return self.__serialize(data, ctx)