@@ -1793,12 +1793,12 @@ def setup_class(cls):
17931793 cls .cluster = Cluster (protocol_version = PROTOCOL_VERSION )
17941794 cls .keyspace_name = cls .__name__ .lower ()
17951795 cls .session = cls .cluster .connect ()
1796- cls .session .execute ("CREATE KEYSPACE IF NOT EXISTS %s WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}" % cls .keyspace_name )
1796+ cls .session .execute ("CREATE KEYSPACE %s WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}" % cls .keyspace_name )
17971797 cls .session .set_keyspace (cls .keyspace_name )
17981798
17991799 @classmethod
18001800 def teardown_class (cls ):
1801- cls .session .execute ("DROP KEYSPACE IF EXISTS %s" % cls .keyspace_name )
1801+ cls .session .execute ("DROP KEYSPACE %s" % cls .keyspace_name )
18021802 cls .cluster .shutdown ()
18031803
18041804 def _run_on_all_nodes (self , query , params ):
@@ -1821,8 +1821,8 @@ def test_keyspace_bad_options(self):
18211821 self ._run_on_all_nodes ('UPDATE system.schema_keyspaces SET strategy_options=%s' + where_cls , (strategy_options ,))
18221822
18231823 def test_keyspace_bad_index (self ):
1824- self .session .execute ('CREATE TABLE %s (k int PRIMARY KEY, v int)' % self .function_name )
1825- self .session .execute ('CREATE INDEX ON %s(v)' % self .function_name )
1824+ self .session .execute ('CREATE TABLE %s (k int PRIMARY KEY, v int)' % self .function_name , timeout = 30.0 )
1825+ self .session .execute ('CREATE INDEX ON %s(v)' % self .function_name , timeout = 30.0 )
18261826 where_cls = " WHERE keyspace_name='%s' AND columnfamily_name='%s' AND column_name='v'" \
18271827 % (self .keyspace_name , self .function_name )
18281828 index_options = self .session .execute ('SELECT index_options FROM system.schema_columns' + where_cls )[0 ].index_options
@@ -1838,7 +1838,7 @@ def test_keyspace_bad_index(self):
18381838 self ._run_on_all_nodes ('UPDATE system.schema_columns SET index_options=%s' + where_cls , (index_options ,))
18391839
18401840 def test_table_bad_comparator (self ):
1841- self .session .execute ('CREATE TABLE %s (k int PRIMARY KEY, v int)' % self .function_name )
1841+ self .session .execute ('CREATE TABLE %s (k int PRIMARY KEY, v int)' % self .function_name , timeout = 30.0 )
18421842 where_cls = " WHERE keyspace_name='%s' AND columnfamily_name='%s'" % (self .keyspace_name , self .function_name )
18431843 comparator = self .session .execute ('SELECT comparator FROM system.schema_columnfamilies' + where_cls )[0 ].comparator
18441844 try :
@@ -1854,7 +1854,7 @@ def test_table_bad_comparator(self):
18541854
18551855 @unittest .skipUnless (PROTOCOL_VERSION >= 3 , "Requires protocol version 3+" )
18561856 def test_user_type_bad_typename (self ):
1857- self .session .execute ('CREATE TYPE %s (i int, d double)' % self .function_name )
1857+ self .session .execute ('CREATE TYPE %s (i int, d double)' % self .function_name , timeout = 60.0 )
18581858 where_cls = " WHERE keyspace_name='%s' AND type_name='%s'" % (self .keyspace_name , self .function_name )
18591859 field_types = self .session .execute ('SELECT field_types FROM system.schema_usertypes' + where_cls )[0 ].field_types
18601860 try :
0 commit comments