Skip to content

Commit c77a5c6

Browse files
committed
Fixed style
1 parent ccdcf6b commit c77a5c6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/tests/fq/yds/test_row_dispatcher.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ def test_read_raw_format_with_row_dispatcher(self, kikimr, client):
8989
)
9090
connections = client.list_connections(fq.Acl.Visibility.PRIVATE).result.connection
9191
assert len(connections) == 1
92-
assert connections[0].content.setting.data_streams.shared_reading == True
92+
assert connections[0].content.setting.data_streams.shared_reading is True
9393

9494
self.init_topics("test_read_raw_format_without_row_dispatcher", create_output=False)
9595
output_topic = "pq_test_pq_read_write_output"
@@ -106,7 +106,7 @@ def test_read_raw_format_with_row_dispatcher(self, kikimr, client):
106106
assert self.read_stream(len(data), topic_path=output_topic) == data
107107
wait_actor_count(kikimr, "FQ_ROW_DISPATCHER_SESSION", 1)
108108
stop_yds_query(client, query_id)
109-
109+
110110
sql2 = Rf'''INSERT INTO {YDS_CONNECTION}.`{output_topic}`
111111
SELECT * FROM {YDS_CONNECTION}.`{self.input_topic}` WITH (format=raw, SCHEMA (data String NOT NULL))
112112
WHERE data != "romashka";'''

0 commit comments

Comments
 (0)