Skip to content

Commit d7bffd8

Browse files
committed
remove unsupported args in sync writer
1 parent 48d1b36 commit d7bffd8

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

ydb/_topic_writer/topic_writer_sync.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -92,25 +92,22 @@ def wait_init(self, timeout: Optional[TimeoutType] = None) -> PublicWriterInitIn
9292

9393
def write(
9494
self,
95-
message: Union[PublicMessage, List[PublicMessage]],
96-
*args: Optional[PublicMessage],
95+
messages: Union[PublicMessage, List[PublicMessage]],
9796
timeout: Union[float, None] = None,
9897
):
99-
self._call_sync(self._async_writer.write(message, *args), timeout=timeout)
98+
self._call_sync(self._async_writer.write(messages), timeout=timeout)
10099

101100
def async_write_with_ack(
102101
self,
103102
messages: Union[MessageType, List[MessageType]],
104-
*args: Optional[MessageType],
105103
) -> Future[Union[PublicWriteResult, List[PublicWriteResult]]]:
106-
return self._call(self._async_writer.write_with_ack(messages, *args))
104+
return self._call(self._async_writer.write_with_ack(messages))
107105

108106
def write_with_ack(
109107
self,
110108
messages: Union[MessageType, List[MessageType]],
111-
*args: Optional[MessageType],
112109
timeout: Union[float, None] = None,
113110
) -> Union[PublicWriteResult, List[PublicWriteResult]]:
114111
return self._call_sync(
115-
self._async_writer.write_with_ack(messages, *args), timeout=timeout
112+
self._async_writer.write_with_ack(messages), timeout=timeout
116113
)

0 commit comments

Comments
 (0)