|
12 | 12 | # See the License for the specific language governing permissions and
|
13 | 13 | # limitations under the License.
|
14 | 14 |
|
| 15 | +import os |
15 | 16 | import unittest
|
16 |
| - |
17 | 17 | from collections import namedtuple
|
18 | 18 | from functools import partial
|
19 |
| -import six |
20 | 19 |
|
| 20 | +import six |
21 | 21 | from cassandra import InvalidRequest
|
22 | 22 | from cassandra.cluster import UserTypeDoesNotExist, ExecutionProfile, EXEC_PROFILE_DEFAULT
|
23 | 23 | from cassandra.query import dict_factory
|
|
33 | 33 |
|
34 | 34 |
|
35 | 35 | def setup_module():
|
| 36 | + os.environ['SCYLLA_EXT_OPTS'] = "--smp 1" |
36 | 37 | use_singledc()
|
37 | 38 | update_datatypes()
|
38 | 39 |
|
@@ -125,15 +126,15 @@ def test_can_register_udt_before_connecting(self):
|
125 | 126 |
|
126 | 127 | s.execute("""
|
127 | 128 | CREATE KEYSPACE udt_test_register_before_connecting
|
128 |
| - WITH replication = { 'class' : 'SimpleStrategy', 'replication_factor': '1' } |
| 129 | + WITH replication = { 'class' : 'SimpleStrategy', 'replication_factor': '3' } |
129 | 130 | """)
|
130 | 131 | s.set_keyspace("udt_test_register_before_connecting")
|
131 | 132 | s.execute("CREATE TYPE user (age int, name text)")
|
132 | 133 | s.execute("CREATE TABLE mytable (a int PRIMARY KEY, b frozen<user>)")
|
133 | 134 |
|
134 | 135 | s.execute("""
|
135 | 136 | CREATE KEYSPACE udt_test_register_before_connecting2
|
136 |
| - WITH replication = { 'class' : 'SimpleStrategy', 'replication_factor': '1' } |
| 137 | + WITH replication = { 'class' : 'SimpleStrategy', 'replication_factor': '3' } |
137 | 138 | """)
|
138 | 139 | s.set_keyspace("udt_test_register_before_connecting2")
|
139 | 140 | s.execute("CREATE TYPE user (state text, is_cool boolean)")
|
|
0 commit comments