Skip to content

Commit

Permalink
Update python/pyarrow/_dataset_parquet_encryption.pyx
Browse files Browse the repository at this point in the history
Co-authored-by: scoder <[email protected]>
  • Loading branch information
jorisvandenbossche and scoder committed Oct 10, 2023
1 parent 1f8ee19 commit 6777353
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions python/pyarrow/_dataset_parquet_encryption.pyx
Original file line number Diff line number Diff line change
Expand Up @@ -154,17 +154,17 @@ cdef class ParquetDecryptionConfig(_Weakrefable):
return self.c_config


def set_encryption_config(ParquetFileWriteOptions opts, config):
cdef shared_ptr[CParquetEncryptionConfig] c_config
if not isinstance(config, ParquetEncryptionConfig):
raise ValueError("config must be a ParquetEncryptionConfig")
c_config = (<ParquetEncryptionConfig>config).unwrap()
def set_encryption_config(
ParquetFileWriteOptions opts not None,
ParquetEncryptionConfig config not None
):
cdef shared_ptr[CParquetEncryptionConfig] c_config = config.unwrap()
opts.parquet_options.parquet_encryption_config = c_config


def set_decryption_config(ParquetFragmentScanOptions opts, config):
cdef shared_ptr[CParquetDecryptionConfig] c_config
if not isinstance(config, ParquetDecryptionConfig):
raise ValueError("config must be a ParquetDecryptionConfig")
c_config = (<ParquetDecryptionConfig>config).unwrap()
def set_decryption_config(
ParquetFragmentScanOptions opts not None,
ParquetDecryptionConfig config not None
):
cdef shared_ptr[CParquetDecryptionConfig] c_config = config.unwrap()
opts.parquet_options.parquet_decryption_config = c_config

0 comments on commit 6777353

Please sign in to comment.