File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -36,7 +36,7 @@ class Table:
3636 columns : dict [str , type ]
3737
3838 def verify (self , data : dict [str , Any ]):
39- """Verify if the data has the correct columns and types.
39+ """Verifies if the data has the correct columns and types.
4040
4141 Validates that the provided data dictionary contains the expected columns
4242 with correct data types according to the table schema definition.
Original file line number Diff line number Diff line change 2222
2323
2424def prepare_all_tables ():
25- """Prepare and create all ClickHouse tables from SQL files.
25+ """Prepares and creates all ClickHouse tables from SQL files.
2626
2727 Reads all SQL files from the CREATE_TABLES_DIRECTORY and executes them
2828 to create the required database tables for monitoring data storage.
@@ -80,7 +80,7 @@ def __init__(self):
8080 self .batch_sender = ClickHouseBatchSender ()
8181
8282 async def start (self ):
83- """Start the monitoring agent to consume and process data continuously.
83+ """Starts the monitoring agent to consume and process data continuously.
8484
8585 Runs an infinite loop to consume messages from Kafka topics, deserialize
8686 the data according to table schemas, and forward it to the batch sender
You can’t perform that action at this time.
0 commit comments