File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -219,14 +219,17 @@ def __init__(
219219
220220 write_type = DefaultWriteOptions .write_type .value
221221 write_precision = DefaultWriteOptions .write_precision .value
222+ write_no_sync = DefaultWriteOptions .no_sync .value
222223 if isinstance (write_client_options , dict ) and write_client_options .get ('write_options' ) is not None :
223224 write_opts = write_client_options ['write_options' ]
224225 write_type = getattr (write_opts , 'write_type' , write_type )
225226 write_precision = getattr (write_opts , 'write_precision' , write_precision )
227+ write_no_sync = getattr (write_opts , 'no_sync' , write_no_sync )
226228
227229 write_options = WriteOptions (
228230 write_type = write_type ,
229231 write_precision = write_precision ,
232+ no_sync = write_no_sync ,
230233 )
231234
232235 self ._write_client_options = {
You can’t perform that action at this time.
0 commit comments