Skip to content

Commit 897af1a

Browse files
committed
pep8 cleanup
1 parent 094b447 commit 897af1a

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

cassandra/cluster.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1118,7 +1118,6 @@ def add_execution_profile(self, name, profile, pool_wait_timeout=5):
11181118
if not_done:
11191119
raise OperationTimedOut("Failed to create all new connection pools in the %ss timeout.")
11201120

1121-
11221121
def get_min_requests_per_connection(self, host_distance):
11231122
return self._min_requests_per_connection[host_distance]
11241123

@@ -2061,7 +2060,6 @@ def default_serial_consistency_level(self, cl):
20612060
.. versionadded:: 3.8.0
20622061
"""
20632062

2064-
20652063
encoder = None
20662064
"""
20672065
A :class:`~cassandra.encoder.Encoder` instance that will be used when
@@ -2251,7 +2249,6 @@ def _create_response_future(self, query, parameters, trace, custom_payload, time
22512249
load_balancing_policy = execution_profile.load_balancing_policy
22522250
spec_exec_policy = execution_profile.speculative_execution_policy
22532251

2254-
22552252
fetch_size = query.fetch_size
22562253
if fetch_size is FETCH_SIZE_UNSET and self._protocol_version >= 2:
22572254
fetch_size = self.default_fetch_size

tests/integration/simulacron/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,4 +56,3 @@ def tearDownClass(cls):
5656
if cls.cluster:
5757
cls.cluster.shutdown()
5858
stop_simulacron()
59-

0 commit comments

Comments
 (0)