Skip to content

Commit 1fda0ff

Browse files
authored
update checkpointstores (Azure#38936)
1 parent 7c22c81 commit 1fda0ff

File tree

2 files changed

+5
-5
lines changed
  • sdk/eventhub
    • azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio
    • azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob

2 files changed

+5
-5
lines changed

sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/azure/eventhub/extensions/checkpointstoreblobaio/_blobstoragecsaio.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
from collections import defaultdict
99
import asyncio
1010
from azure.eventhub.exceptions import OwnershipLostError # type: ignore
11-
from azure.eventhub.aio import CheckpointStore # type: ignore # pylint: disable=no-name-in-module
11+
from azure.eventhub.aio import CheckpointStore # type: ignore
1212
from azure.core.exceptions import ResourceModifiedError, ResourceExistsError, ResourceNotFoundError # type: ignore
1313
from ._vendor.storage.blob.aio import ContainerClient, BlobClient
1414
from ._vendor.storage.blob._shared.base_client import parse_connection_str
@@ -67,7 +67,7 @@ def __init__(
6767
self._cached_blob_clients = defaultdict() # type: Dict[str, BlobClient]
6868

6969
@classmethod
70-
def from_connection_string(
70+
def from_connection_string( # pylint:disable=docstring-keyword-should-match-keyword-only
7171
cls,
7272
conn_str: str,
7373
container_name: str,
@@ -222,7 +222,7 @@ async def list_ownership(
222222
}
223223
result.append(ownership)
224224
return result
225-
except Exception as error: # pylint:disable=broad-except
225+
except Exception as error:
226226
logger.warning(
227227
"An exception occurred during list_ownership for "
228228
"namespace %r eventhub %r consumer group %r. "

sdk/eventhub/azure-eventhub-checkpointstoreblob/azure/eventhub/extensions/checkpointstoreblob/_blobstoragecs.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ def __init__(
8989
self._cached_blob_clients = defaultdict() # type: Dict[str, BlobClient]
9090

9191
@classmethod
92-
def from_connection_string(
92+
def from_connection_string( # pylint:disable=docstring-keyword-should-match-keyword-only
9393
cls,
9494
conn_str: str,
9595
container_name: str,
@@ -243,7 +243,7 @@ def list_ownership(
243243
}
244244
result.append(ownership)
245245
return result
246-
except Exception as error: # pylint:disable=broad-except
246+
except Exception as error:
247247
logger.warning(
248248
"An exception occurred during list_ownership for "
249249
"namespace %r eventhub %r consumer group %r. "

0 commit comments

Comments
 (0)