Skip to content

Commit db96ffa

Browse files
committed
Don't try to enable insights is disabled
1 parent bdb5f53 commit db96ffa

File tree

1 file changed

+13
-12
lines changed

1 file changed

+13
-12
lines changed

cassandra/cluster.py

Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2546,18 +2546,19 @@ def __init__(self, cluster, hosts, keyspace=None):
25462546
self.session_id = uuid.uuid4()
25472547
self._graph_paging_available = self._check_graph_paging_available()
25482548

2549-
cc_host = self.cluster.get_control_connection_host()
2550-
valid_insights_version = (cc_host and version_supports_insights(cc_host.dse_version))
2551-
if self.cluster.monitor_reporting_enabled and valid_insights_version:
2552-
self._monitor_reporter = MonitorReporter(
2553-
interval_sec=self.cluster.monitor_reporting_interval,
2554-
session=self,
2555-
)
2556-
else:
2557-
if cc_host:
2558-
log.debug('Not starting MonitorReporter thread for Insights; '
2559-
'not supported by server version {v} on '
2560-
'ControlConnection host {c}'.format(v=cc_host.release_version, c=cc_host))
2549+
if self.cluster.monitor_reporting_enabled:
2550+
cc_host = self.cluster.get_control_connection_host()
2551+
valid_insights_version = (cc_host and version_supports_insights(cc_host.dse_version))
2552+
if valid_insights_version:
2553+
self._monitor_reporter = MonitorReporter(
2554+
interval_sec=self.cluster.monitor_reporting_interval,
2555+
session=self,
2556+
)
2557+
else:
2558+
if cc_host:
2559+
log.debug('Not starting MonitorReporter thread for Insights; '
2560+
'not supported by server version {v} on '
2561+
'ControlConnection host {c}'.format(v=cc_host.release_version, c=cc_host))
25612562

25622563
log.debug('Started Session with client_id {} and session_id {}'.format(self.cluster.client_id,
25632564
self.session_id))

0 commit comments

Comments
 (0)