Skip to content

Commit ae49de0

Browse files
authored
[Storage]Address comments for STG78 GA (Azure#20491)
* [Storage]Address comments for STG78 GA * [Storage]Address comments for STG78 GA
1 parent 1099723 commit ae49de0

File tree

7 files changed

+21
-21
lines changed

7 files changed

+21
-21
lines changed

sdk/storage/azure-storage-blob/azure/storage/blob/_blob_client.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -853,9 +853,9 @@ def _quick_query_options(self, query_expression,
853853
# type: (str, **Any) -> Dict[str, Any]
854854
delimiter = '\n'
855855
input_format = kwargs.pop('blob_format', None)
856-
if input_format == QuickQueryDialect.DelimitedJsonDialect:
856+
if input_format == QuickQueryDialect.DelimitedJson:
857857
input_format = DelimitedJsonDialect()
858-
if input_format == QuickQueryDialect.DelimitedTextDialect:
858+
if input_format == QuickQueryDialect.DelimitedText:
859859
input_format = DelimitedTextDialect()
860860
input_parquet_format = input_format == "ParquetDialect"
861861
if input_format and not input_parquet_format:
@@ -868,9 +868,9 @@ def _quick_query_options(self, query_expression,
868868
raise ValueError("The Type of blob_format can only be DelimitedTextDialect or "
869869
"DelimitedJsonDialect or ParquetDialect")
870870
output_format = kwargs.pop('output_format', None)
871-
if output_format == QuickQueryDialect.DelimitedJsonDialect:
871+
if output_format == QuickQueryDialect.DelimitedJson:
872872
output_format = DelimitedJsonDialect()
873-
if output_format == QuickQueryDialect.DelimitedTextDialect:
873+
if output_format == QuickQueryDialect.DelimitedText:
874874
output_format = DelimitedTextDialect()
875875
if output_format:
876876
if output_format == "ParquetDialect":

sdk/storage/azure-storage-blob/azure/storage/blob/_models.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,9 @@ class PremiumPageBlobTier(str, Enum):
7070
class QuickQueryDialect(str, Enum):
7171
"""Specifies the quick query input/output dialect."""
7272

73-
DelimitedTextDialect = 'DelimitedTextDialect'
74-
DelimitedJsonDialect = 'DelimitedJsonDialect'
75-
ParquetDialect = 'ParquetDialect'
73+
DelimitedText = 'DelimitedTextDialect'
74+
DelimitedJson = 'DelimitedJsonDialect'
75+
Parquet = 'ParquetDialect'
7676

7777

7878
class SequenceNumberAction(str, Enum):
@@ -321,7 +321,7 @@ class ContainerProperties(DictMixin):
321321
Represents whether the container has an immutability policy.
322322
:ivar bool has_legal_hold:
323323
Represents whether the container has a legal hold.
324-
:ivar bool is_immutable_storage_with_versioning_enabled:
324+
:ivar bool immutable_storage_with_versioning_enabled:
325325
Represents whether immutable storage with versioning enabled on the container.
326326
327327
.. versionadded:: 12.10.0
@@ -349,7 +349,7 @@ def __init__(self, **kwargs):
349349
self.has_legal_hold = kwargs.get('x-ms-has-legal-hold')
350350
self.metadata = kwargs.get('metadata')
351351
self.encryption_scope = None
352-
self.is_immutable_storage_with_versioning_enabled = kwargs.get('x-ms-immutable-storage-with-versioning-enabled')
352+
self.immutable_storage_with_versioning_enabled = kwargs.get('x-ms-immutable-storage-with-versioning-enabled')
353353
default_encryption_scope = kwargs.get('x-ms-default-encryption-scope')
354354
if default_encryption_scope:
355355
self.encryption_scope = ContainerEncryptionScope(
@@ -366,7 +366,7 @@ def _from_generated(cls, generated):
366366
props.lease = LeaseProperties._from_generated(generated) # pylint: disable=protected-access
367367
props.public_access = generated.properties.public_access
368368
props.has_immutability_policy = generated.properties.has_immutability_policy
369-
props.is_immutable_storage_with_versioning_enabled = \
369+
props.immutable_storage_with_versioning_enabled = \
370370
generated.properties.is_immutable_storage_with_versioning_enabled
371371
props.deleted = generated.deleted
372372
props.version = generated.version

sdk/storage/azure-storage-blob/tests/test_container.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ def test_list_containers(self, resource_group, location, storage_account, storag
228228
self.assertNamedItemInContainer(containers, container.container_name)
229229
self.assertIsNotNone(containers[0].has_immutability_policy)
230230
self.assertIsNotNone(containers[0].has_legal_hold)
231-
self.assertIsNotNone(containers[0].is_immutable_storage_with_versioning_enabled)
231+
self.assertIsNotNone(containers[0].immutable_storage_with_versioning_enabled)
232232

233233
@GlobalStorageAccountPreparer()
234234
def test_list_containers_with_prefix(self, resource_group, location, storage_account, storage_account_key):
@@ -401,7 +401,7 @@ def test_get_container_properties(self, resource_group, location, storage_accoun
401401
# Assert
402402
self.assertIsNotNone(props)
403403
self.assertDictEqual(props.metadata, metadata)
404-
self.assertIsNotNone(props.is_immutable_storage_with_versioning_enabled)
404+
self.assertIsNotNone(props.immutable_storage_with_versioning_enabled)
405405
# self.assertEqual(props.lease.duration, 'infinite')
406406
# self.assertEqual(props.lease.state, 'leased')
407407
# self.assertEqual(props.lease.status, 'locked')

sdk/storage/azure-storage-blob/tests/test_container_async.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,7 @@ async def test_list_containers(self, resource_group, location, storage_account,
299299
self.assertNamedItemInContainer(containers, container.container_name)
300300
self.assertIsNotNone(containers[0].has_immutability_policy)
301301
self.assertIsNotNone(containers[0].has_legal_hold)
302-
self.assertIsNotNone(containers[0].is_immutable_storage_with_versioning_enabled)
302+
self.assertIsNotNone(containers[0].immutable_storage_with_versioning_enabled)
303303

304304
@GlobalStorageAccountPreparer()
305305
@AsyncStorageTestCase.await_prepared_test
@@ -500,7 +500,7 @@ async def test_get_container_properties(self, resource_group, location, storage_
500500
# Assert
501501
self.assertIsNotNone(props)
502502
self.assertDictEqual(props.metadata, metadata)
503-
self.assertIsNotNone(props.is_immutable_storage_with_versioning_enabled)
503+
self.assertIsNotNone(props.immutable_storage_with_versioning_enabled)
504504
# self.assertEqual(props.lease.duration, 'infinite')
505505
# self.assertEqual(props.lease.state, 'leased')
506506
# self.assertEqual(props.lease.status, 'locked')

sdk/storage/azure-storage-blob/tests/test_quick_query.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -986,7 +986,7 @@ def test_quick_query_input_in_parquet_format(self, resource_group, location, sto
986986
with open(parquet_path, "rb") as parquet_data:
987987
blob_client.upload_blob(parquet_data, overwrite=True)
988988

989-
reader = blob_client.query_blob(expression, blob_format=QuickQueryDialect.ParquetDialect)
989+
reader = blob_client.query_blob(expression, blob_format=QuickQueryDialect.Parquet)
990990
real_data = reader.readall()
991991

992992
self.assertEqual(real_data, expected_data)

sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_models.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -724,9 +724,9 @@ class ArrowDialect(BlobArrowDialect):
724724
class QuickQueryDialect(str, Enum):
725725
"""Specifies the quick query input/output dialect."""
726726

727-
DelimitedTextDialect = 'DelimitedTextDialect'
728-
DelimitedJsonDialect = 'DelimitedJsonDialect'
729-
ParquetDialect = 'ParquetDialect'
727+
DelimitedText = 'DelimitedTextDialect'
728+
DelimitedJson = 'DelimitedJsonDialect'
729+
Parquet = 'ParquetDialect'
730730

731731

732732
class ArrowType(str, Enum):

sdk/storage/azure-storage-file-datalake/tests/test_quick_query.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -905,7 +905,7 @@ def test_quick_query_input_in_parquet_format(self, datalake_storage_account_name
905905
with open(parquet_path, "rb") as parquet_data:
906906
file_client.upload_data(parquet_data, overwrite=True)
907907

908-
reader = file_client.query_file(expression, file_format=QuickQueryDialect.ParquetDialect)
908+
reader = file_client.query_file(expression, file_format=QuickQueryDialect.Parquet)
909909
real_data = reader.readall()
910910

911911
self.assertEqual(real_data, expected_data)
@@ -924,7 +924,7 @@ def test_quick_query_output_in_parquet_format(self, datalake_storage_account_nam
924924

925925
with self.assertRaises(ValueError):
926926
file_client.query_file(
927-
expression, file_format=QuickQueryDialect.ParquetDialect,
928-
output_format=QuickQueryDialect.ParquetDialect)
927+
expression, file_format=QuickQueryDialect.Parquet,
928+
output_format=QuickQueryDialect.Parquet)
929929

930930
# ------------------------------------------------------------------------------

0 commit comments

Comments
 (0)