@@ -31,11 +31,11 @@ def test_basic(self):
3131 def test_bad_table (self ):
3232 buf = qi .Buffer ()
3333 with self .assertRaisesRegex (
34- qi .IngError ,
34+ qi .IngressError ,
3535 'Table names must have a non-zero length' ):
3636 buf .row ('' , symbols = {'sym1' : 'val1' })
3737 with self .assertRaisesRegex (
38- qi .IngError ,
38+ qi .IngressError ,
3939 'Bad string "x..y": Found invalid dot `.` at position 2.' ):
4040 buf .row ('x..y' , symbols = {'sym1' : 'val1' })
4141
@@ -47,11 +47,11 @@ def test_symbol(self):
4747 def test_bad_symbol_column_name (self ):
4848 buf = qi .Buffer ()
4949 with self .assertRaisesRegex (
50- qi .IngError ,
50+ qi .IngressError ,
5151 'Column names must have a non-zero length.' ):
5252 buf .row ('tbl1' , symbols = {'' : 'val1' })
5353 with self .assertRaisesRegex (
54- qi .IngError ,
54+ qi .IngressError ,
5555 'Bad string "sym.bol": '
5656 'Column names can\' t contain a \' .\' character, '
5757 'which was found at byte position 3.' ):
@@ -125,7 +125,7 @@ def test_row_before_connect(self):
125125 try :
126126 sender = qi .Sender ('localhost' , 12345 )
127127 sender .row ('tbl1' , symbols = {'sym1' : 'val1' })
128- with self .assertRaisesRegex (qi .IngError , 'Not connected' ):
128+ with self .assertRaisesRegex (qi .IngressError , 'Not connected' ):
129129 sender .flush ()
130130 finally :
131131 sender .close ()
@@ -134,7 +134,7 @@ def test_flush_1(self):
134134 with Server () as server :
135135 with qi .Sender ('localhost' , server .port ) as sender :
136136 server .accept ()
137- with self .assertRaisesRegex (qi .IngError , 'Column names' ):
137+ with self .assertRaisesRegex (qi .IngressError , 'Column names' ):
138138 sender .row ('tbl1' , symbols = {'...bad name..' : 'val1' })
139139 self .assertEqual (str (sender ), '' )
140140 sender .flush ()
@@ -149,14 +149,14 @@ def test_flush_2(self):
149149 server .close ()
150150
151151 # We enter a bad state where we can't flush again.
152- with self .assertRaises (qi .IngError ):
152+ with self .assertRaises (qi .IngressError ):
153153 for _ in range (1000 ):
154154 time .sleep (0.01 )
155155 sender .row ('tbl1' , symbols = {'a' : 'b' })
156156 sender .flush ()
157157
158158 # We should still be in a bad state.
159- with self .assertRaises (qi .IngError ):
159+ with self .assertRaises (qi .IngressError ):
160160 sender .row ('tbl1' , symbols = {'a' : 'b' })
161161 sender .flush ()
162162
@@ -167,7 +167,7 @@ def test_flush_3(self):
167167 # Same as test_flush_2, but we catch the exception _outside_ the
168168 # sender's `with` block, to ensure no exceptions get trapped.
169169 with Server () as server :
170- with self .assertRaises (qi .IngError ):
170+ with self .assertRaises (qi .IngressError ):
171171 with qi .Sender ('localhost' , server .port ) as sender :
172172 server .accept ()
173173 server .close ()
0 commit comments