Skip to content

Commit 25e07d7

Browse files
committed
lint fixes
1 parent fea0465 commit 25e07d7

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

examples/topic/basic_example.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ async def connect(endpoint: str, database: str) -> ydb.aio.Driver:
99
config = ydb.DriverConfig(endpoint=endpoint, database=database)
1010
# config.credentials = ydb.credentials_from_env_variables()
1111
driver = ydb.aio.Driver(config)
12-
await driver.wait(5,fail_fast=True)
12+
await driver.wait(5, fail_fast=True)
1313
return driver
1414

1515

@@ -25,10 +25,7 @@ async def create_topic(driver: ydb.aio.Driver, topic: str, consumer: str):
2525
async def write_messages(driver: ydb.aio.Driver, topic: str):
2626
async with driver.topic_client.writer(topic) as writer:
2727
for i in range(10):
28-
mess = ydb.TopicWriterMessage(
29-
data = f"mess-{i}",
30-
metadata_items= {"index": f"{i}"}
31-
)
28+
mess = ydb.TopicWriterMessage(data=f"mess-{i}", metadata_items={"index": f"{i}"})
3229
await writer.write(mess)
3330
await asyncio.sleep(1)
3431

0 commit comments

Comments
 (0)