diff --git a/.vscode/cspell.json b/.vscode/cspell.json index 759d61253ee0..e802842e0496 100644 --- a/.vscode/cspell.json +++ b/.vscode/cspell.json @@ -56,7 +56,6 @@ "sdk/eventhub/azure-eventhub-checkpointstoretable/**", "sdk/eventgrid/azure-eventgrid/**", "sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/**", - "sdk/eventhub/azure-eventhub-checkpointstoreblob/**", "sdk/eventhub/azure-eventhub/**", "sdk/graphrbac/azure-graphrbac/**", "sdk/formrecognizer/azure-ai-formrecognizer/samples/sample_forms/**", @@ -182,6 +181,7 @@ "illumos", "imds", "inotify", + "ints", "iohttp", "IOHTTP", "inprogress", @@ -217,6 +217,7 @@ "LPCWSTR", "Lucene", "mbps", + "mday", "mibps", "mgmt", "mhsm", @@ -231,6 +232,7 @@ "mydirectory", "myfile", "nazsdk", + "nbytes", "noarch", "NOPERM", "northcentralus", @@ -243,6 +245,7 @@ "onboarded", "onmicrosoft", "owasp", + "ownerid", "PBYTE", "PCREDENTIAL", "perfmon", @@ -256,6 +259,7 @@ "popen", "prebuilts", "premf", + "prevsnapshot", "pschema", "PSECRET", "pyfuncitem", @@ -292,6 +296,8 @@ "skus", "southcentralus", "ssis", + "struct", + "STRUCT", "substringof", "systemperf", "tenvparallel", @@ -303,8 +309,10 @@ "uamqp", "uksouth", "ukwest", + "unpad", "unpadder", "unredacted", + "unseekable", "unsubscriptable", "upns", "upserted", @@ -322,8 +330,10 @@ "utid", "Uvsc", "vcrpy", + "vendored", "verifysdist", "verifywhl", + "versionid", "vmimage", "vmss", "vmwarecloudsimple", @@ -493,6 +503,22 @@ "mmspecial" ] }, + { + "filename": "sdk/eventhub/azure-eventhub-checkpointstoreblob/**", + "words": [ + "blobstoragecs", + "blobstoragepm", + "rscc", + "rscd", + "rsce", + "rscl", + "rsct", + "saoid", + "scid", + "skoid", + "suoid" + ] + }, { "filename": "sdk/formrecognizer/azure-ai-formrecognizer/tests/*.py", "words": [ diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md b/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md index f9ed96f90c70..b19f65ea9305 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/CHANGELOG.md @@ -7,7 +7,7 @@ This version and all future versions will require Python 3.7+. Python 2.7 and 3. ### Bugs Fixed - Fixed a bug with `BlobCheckpointStore.claim_ownership` mutating the `ownership_list` argument to no longer mutate the argument. -- Updated `azure-core` dependecy to 1.20.1 to fix `cchardet` ImportError. +- Updated `azure-core` dependency to 1.20.1 to fix `cchardet` ImportError. ## 1.1.4 (2021-04-07) diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_container_client.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_container_client.py index 8788d14b704a..5bc4835b0c3b 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_container_client.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_container_client.py @@ -1144,7 +1144,7 @@ def delete_blobs(self, *blobs, **kwargs): key: 'name', value type: str snapshot you want to delete: key: 'snapshot', value type: str - whether to delete snapthots when deleting blob: + whether to delete snapshots when deleting blob: key: 'delete_snapshots', value: 'include' or 'only' if the blob modified or not: key: 'if_modified_since', 'if_unmodified_since', value type: datetime diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_download.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_download.py index 46e59e5d2492..70a4eb08dbc5 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_download.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_download.py @@ -417,7 +417,7 @@ def _initial_request(self): # If the file is small, the download is complete at this point. # If file size is large, download the rest of the file in chunks. if response.properties.size != self.size: - # Lock on the etag. This can be overriden by the user by specifying '*' + # Lock on the etag. This can be overridden by the user by specifying '*' if self._request_options.get("modified_access_conditions"): if not self._request_options["modified_access_conditions"].if_match: self._request_options["modified_access_conditions"].if_match = response.properties.etag diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/avro/schema.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/avro/schema.py index ffe28530167f..34fa5980a5f5 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/avro/schema.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/avro/schema.py @@ -259,7 +259,7 @@ def __init__(self, name, namespace=None): # Validate the fullname: if _RE_FULL_NAME.match(self._fullname) is None: raise SchemaParseException( - 'Invalid schema name %r infered from name %r and namespace %r.' + 'Invalid schema name %r inferred from name %r and namespace %r.' % (self._fullname, self._name, self._namespace)) def __eq__(self, other): @@ -439,9 +439,9 @@ def name_ref(self, names): """Reports this schema name relative to the specified name tracker. Args: - names: Avro name tracker to relativise this schema name against. + names: Avro name tracker to relativize this schema name against. Returns: - This schema name, relativised against the specified name tracker. + This schema name, relativized against the specified name tracker. """ if self.namespace == names.default_namespace: return self.name diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/encryption.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/encryption.py index 62607cc0cf85..56ac384d9efe 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/encryption.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/encryption.py @@ -459,7 +459,7 @@ def encrypt_queue_message(message, key_encryption_key): Returns a json-formatted string containing the encrypted message and the encryption metadata. :param object message: - The plain text messge to be encrypted. + The plain text message to be encrypted. :param object key_encryption_key: The user-provided key-encryption-key. Must implement the following methods: wrap_key(key)--wraps the specified key using an algorithm of the user's choice. diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/policies.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/policies.py index 2db5048b67ef..d582b36a3c8e 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/policies.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/policies.py @@ -83,7 +83,7 @@ def is_retry(response, mode): """ status = response.http_response.status_code if 300 <= status < 500: - # An exception occured, but in most cases it was expected. Examples could + # An exception occurred, but in most cases it was expected. Examples could # include a 309 Conflict or 412 Precondition Failed. if status == 404 and mode == LocationMode.SECONDARY: # Response code 404 should be retried if secondary was used. diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/request_handlers.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/request_handlers.py index 4f15b65a4b6d..50f463482d24 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/request_handlers.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/_shared/request_handlers.py @@ -130,7 +130,7 @@ def validate_and_format_range_headers( range_validation = None if check_content_md5: if start_range is None or end_range is None: - raise ValueError("Both start and end range requied for MD5 content validation.") + raise ValueError("Both start and end range required for MD5 content validation.") if end_range - start_range > 4 * 1024 * 1024: raise ValueError("Getting content MD5 for a range greater than 4MB is not supported.") range_validation = 'true' diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_container_client_async.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_container_client_async.py index e26fe2388539..7ad617d77ed5 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_container_client_async.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_container_client_async.py @@ -903,7 +903,7 @@ async def delete_blobs( # pylint: disable=arguments-differ key: 'name', value type: str snapshot you want to delete: key: 'snapshot', value type: str - whether to delete snapthots when deleting blob: + whether to delete snapshots when deleting blob: key: 'delete_snapshots', value: 'include' or 'only' if the blob modified or not: key: 'if_modified_since', 'if_unmodified_since', value type: datetime diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_download_async.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_download_async.py index 44ba51d272d1..3d5e5474d8d7 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_download_async.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_vendor/storage/blob/aio/_download_async.py @@ -164,7 +164,7 @@ class StorageStreamDownloader(object): # pylint: disable=too-many-instance-attr The properties of the blob being downloaded. If only a range of the data is being downloaded, this will be reflected in the properties. :ivar int size: - The size of the total data in the stream. This will be the byte range if speficied, + The size of the total data in the stream. This will be the byte range if specified, otherwise the total size of the blob. """ @@ -316,7 +316,7 @@ async def _initial_request(self): # If the file is small, the download is complete at this point. # If file size is large, download the rest of the file in chunks. if response.properties.size != self.size: - # Lock on the etag. This can be overriden by the user by specifying '*' + # Lock on the etag. This can be overridden by the user by specifying '*' if self._request_options.get('modified_access_conditions'): if not self._request_options['modified_access_conditions'].if_match: self._request_options['modified_access_conditions'].if_match = response.properties.etag