@@ -1225,46 +1225,6 @@ def _target_type_from_refresh_args(keyspace, table, usertype, function, aggregat
1225
1225
return SchemaTargetType .KEYSPACE
1226
1226
return None
1227
1227
1228
- def refresh_schema (self , keyspace = None , table = None , usertype = None , function = None , aggregate = None , max_schema_agreement_wait = None ):
1229
- """
1230
- .. deprecated:: 2.6.0
1231
- Use refresh_*_metadata instead
1232
-
1233
- Synchronously refresh schema metadata.
1234
-
1235
- {keyspace, table, usertype} are string names of the respective entities.
1236
- ``function`` is a :class:`cassandra.UserFunctionDescriptor`.
1237
- ``aggregate`` is a :class:`cassandra.UserAggregateDescriptor`.
1238
-
1239
- If none of ``{keyspace, table, usertype, function, aggregate}`` are specified, the entire schema is refreshed.
1240
-
1241
- If any of ``{keyspace, table, usertype, function, aggregate}`` are specified, ``keyspace`` is required.
1242
-
1243
- If only ``keyspace`` is specified, just the top-level keyspace metadata is refreshed (e.g. replication).
1244
-
1245
- The remaining arguments ``{table, usertype, function, aggregate}``
1246
- are mutually exclusive -- only one may be specified.
1247
-
1248
- By default, the timeout for this operation is governed by :attr:`~.Cluster.max_schema_agreement_wait`
1249
- and :attr:`~.Cluster.control_connection_timeout`.
1250
-
1251
- Passing max_schema_agreement_wait here overrides :attr:`~.Cluster.max_schema_agreement_wait`.
1252
-
1253
- Setting max_schema_agreement_wait <= 0 will bypass schema agreement and refresh schema immediately.
1254
-
1255
- An Exception is raised if schema refresh fails for any reason.
1256
- """
1257
- msg = "refresh_schema is deprecated. Use Cluster.refresh_*_metadata instead."
1258
- warnings .warn (msg , DeprecationWarning )
1259
- log .warning (msg )
1260
-
1261
- self ._validate_refresh_schema (keyspace , table , usertype , function , aggregate )
1262
- target_type = self ._target_type_from_refresh_args (keyspace , table , usertype , function , aggregate )
1263
- if not self .control_connection .refresh_schema (target_type = target_type , keyspace = keyspace , table = table ,
1264
- type = usertype , function = function , aggregate = aggregate ,
1265
- schema_agreement_wait = max_schema_agreement_wait ):
1266
- raise Exception ("Schema was not refreshed. See log for details." )
1267
-
1268
1228
def submit_schema_refresh (self , keyspace = None , table = None , usertype = None , function = None , aggregate = None ):
1269
1229
"""
1270
1230
.. deprecated:: 2.6.0
0 commit comments