@@ -86,7 +86,7 @@ def recovery_impl(self, kikimr, client, yq_version, sql_template, test_name, mes
86
86
87
87
self .init_topics (f"{ test_name } _{ yq_version } " )
88
88
89
- sql = sql_template .format (self .input_topic , self .output_topic );
89
+ sql = sql_template .format (self .input_topic , self .output_topic )
90
90
91
91
client .create_yds_connection ("myyds" , os .getenv ("YDB_DATABASE" ), os .getenv ("YDB_ENDPOINT" ))
92
92
query_id = client .create_query ("simple" , sql , type = fq .QueryContent .QueryType .STREAMING ).result .query_id
@@ -200,7 +200,7 @@ def test_match_recognize(self, kikimr, client, yq_version, request):
200
200
'{"dt": 1696849942000001, "str": "A" }' ,
201
201
'{"dt": 1696849942500001, "str": "B" }' ,
202
202
'{"dt": 1696849943000001, "str": "C" }' ,
203
- '{"dt": 1696849943600001, "str": "D" }' ] # push A+B from TimeOrderRecoverer to MatchRecognize
203
+ '{"dt": 1696849943600001, "str": "D" }' ] # push A+B from TimeOrderRecoverer to MatchRecognize
204
204
205
205
# Before restart:
206
206
# A + B : in MatchRecognize
@@ -211,4 +211,3 @@ def test_match_recognize(self, kikimr, client, yq_version, request):
211
211
expected = [
212
212
'{"a_str":"A","b_str":"B","c_str":"C","dt_begin":1696849942000001,"dt_end":1696849943000001}' ]
213
213
self .recovery_impl (kikimr , client , yq_version , sql , request .node .name , messages_before_restart , messages_after_restart , expected )
214
-
0 commit comments