remove (object) (#33612)

Author: kashifkhan

sdk/eventhub/azure-eventhub/azure/eventhub/_client_base.py

@@ -193,7 +193,7 @@ def _get_backoff_time(retry_mode, backoff_factor, backoff_max, retried_times):
     return min(backoff_max, backoff_value)
 
 
-class EventHubSharedKeyCredential(object):
+class EventHubSharedKeyCredential:
     """The shared access key credential used for authentication.
 
     :param str policy: The name of the shared access policy.
@@ -211,7 +211,7 @@ def get_token(self, *scopes: str, **kwargs: Any) -> AccessToken:  # pylint:disab
         return _generate_sas_token(scopes[0], self.policy, self.key)
 
 
-class EventhubAzureNamedKeyTokenCredential(object):
+class EventhubAzureNamedKeyTokenCredential:
     """The named key credential used for authentication.
 
     :param credential: The AzureNamedKeyCredential that should be used.
@@ -229,7 +229,7 @@ def get_token(self, *scopes: str, **kwargs: Any) -> AccessToken:  # pylint:disab
         return _generate_sas_token(scopes[0], name, key)
 
 
-class EventHubSASTokenCredential(object):
+class EventHubSASTokenCredential:
     """The shared access token credential used for authentication.
 
     :param str token: The shared access token string
@@ -256,7 +256,7 @@ def get_token(self, *scopes: str, **kwargs: Any) -> AccessToken:  # pylint:disab
         return AccessToken(self.token, self.expiry)
 
 
-class EventhubAzureSasTokenCredential(object):
+class EventhubAzureSasTokenCredential:
     """The shared access token credential used for authentication
     when AzureSasCredential is provided.
 
@@ -286,7 +286,7 @@ def get_token(self, *scopes: str, **kwargs: Any) -> AccessToken:  # pylint:disab
         return AccessToken(signature, cast(int, expiry))
 
 
-class ClientBase(object):  # pylint:disable=too-many-instance-attributes
+class ClientBase:  # pylint:disable=too-many-instance-attributes
     def __init__(
         self,
         fully_qualified_namespace: str,

sdk/eventhub/azure-eventhub/azure/eventhub/_common.py

@@ -104,7 +104,7 @@
 )
 
 
-class EventData(object):
+class EventData:
     """The EventData class is a container for event content.
 
     :param body: The data to send in a single message. body can be type of str or bytes.
@@ -520,7 +520,7 @@ def message_id(self, value: str) -> None:
         self._raw_amqp_message.properties.message_id = value
 
 
-class EventDataBatch(object):
+class EventDataBatch:
     """A batch of events.
 
     Sending events in a batch is more performant than sending individual events.

sdk/eventhub/azure-eventhub/azure/eventhub/_configuration.py

@@ -13,7 +13,7 @@
 
 
 
-class Configuration(object):  # pylint:disable=too-many-instance-attributes
+class Configuration:  # pylint:disable=too-many-instance-attributes
     def __init__(
             self,  # pylint:disable=unused-argument
             *,

sdk/eventhub/azure-eventhub/azure/eventhub/_connection_manager.py

@@ -48,7 +48,7 @@ class _ConnectionMode(Enum):
     SeparateConnection = 2
 
 
-class _SharedConnectionManager(object):  # pylint:disable=too-many-instance-attributes
+class _SharedConnectionManager:  # pylint:disable=too-many-instance-attributes
     def __init__(self, **kwargs: Any):
         self._lock = Lock()
         self._conn: Union[Connection, uamqp_Connection] = None
@@ -106,7 +106,7 @@ def reset_connection_if_broken(self) -> None:
                 self._conn = None
 
 
-class _SeparateConnectionManager(object):
+class _SeparateConnectionManager:
     def __init__(self, **kwargs):
         pass
 

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/_eventprocessor_mixin.py

@@ -29,7 +29,7 @@
     )
 
 
-class EventProcessorMixin(object):
+class EventProcessorMixin:
 
     _eventhub_client: Optional[Union[EventHubConsumerClient, EventHubConsumerClientAsync]] = None
     _consumer_group: str = ""

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/checkpoint_store.py

@@ -7,7 +7,7 @@
 from abc import abstractmethod
 
 
-class CheckpointStore(object):
+class CheckpointStore:
     """CheckpointStore deals with the interaction with the chosen storage service.
 
     It can list and claim partition ownerships as well as list and save checkpoints.

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/in_memory_checkpoint_store.py

@@ -12,7 +12,7 @@
 _LOGGER = logging.getLogger(__name__)
 
 
-class _TrieNode(object):
+class _TrieNode:
     def __init__(self, value, is_leaf):
         self.value = value
         self.is_leaf = is_leaf
@@ -64,7 +64,7 @@ def _set_ele_trie(root, ele, keys_path, path_index):
     _set_ele_trie(next_node, ele, keys_path, path_index + 1)
 
 
-class _DictTrie(object):
+class _DictTrie:
     def __init__(self, root_name, keys_path):
         self._root = _TrieNode(root_name, False)
         self._keys_path = keys_path

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/ownership_manager.py

@@ -17,7 +17,7 @@
     from .._producer_client import EventHubProducerClient
 
 
-class OwnershipManager(object):  # pylint:disable=too-many-instance-attributes
+class OwnershipManager:  # pylint:disable=too-many-instance-attributes
     """Increases or decreases the number of partitions owned by an EventProcessor
     so the number of owned partitions are balanced among multiple EventProcessors
 

sdk/eventhub/azure-eventhub/azure/eventhub/_eventprocessor/partition_context.py

@@ -16,7 +16,7 @@
     from .._common import EventData
 
 
-class PartitionContext(object):
+class PartitionContext:
     """Contains partition related context information.
 
     A `PartitionContext` instance will be passed to the event, error and initialization callbacks defined

sdk/eventhub/azure-eventhub/azure/eventhub/_pyamqp/_connection.py

@@ -58,7 +58,7 @@ def get_local_timeout(now, idle_timeout, last_frame_received_time):
     return False
 
 
-class Connection(object):  # pylint:disable=too-many-instance-attributes
+class Connection:  # pylint:disable=too-many-instance-attributes
     """An AMQP Connection.
 
     :ivar str state: The connection state.