diff --git a/skydb/skydb_utils.py b/skydb/skydb_utils.py index dae331b..c891196 100644 --- a/skydb/skydb_utils.py +++ b/skydb/skydb_utils.py @@ -18,7 +18,7 @@ import asyncio -def _equal(condition: dict, key: str, value: str, column_split: list = None) -> bool: +def _equal(condition: dict, key: str, value: str, *args, **kwargs) -> bool: return condition[key] == value @@ -85,7 +85,7 @@ def check_table(table_name: str, seed: str): try: index, revision = registry.get_entry(f"INDEX:{table_name}", timeout=5) return int(index), revision - except Timeout as T: + except Timeout: return None def calibrate_index(self): @@ -105,7 +105,7 @@ def get_index(self) -> int: try: index, revision = self.registry.get_entry(f"INDEX:{self.table_name}", timeout=5) return int(index), revision - except Timeout as T: + except Timeout: self.logger.debug("Initializing the index...") self.registry.set_entry(data_key=f"INDEX:{self.table_name}", data=f"{0}", revision=1) return (0, 1) @@ -192,7 +192,6 @@ def add_rows(self, rows:list) -> list: raise ValueError(f"Column {k} is empty") tasks = [] - row_indices = [] idx = self.index for row in rows: for c in row: @@ -238,7 +237,7 @@ def update_row(self, row_index: int, data: dict): self.logger.debug("Updating row at index: " + str(row_index)) self.logger.debug(data) for k in data.keys(): - old_data, revision = self.registry.get_entry( + _, revision = self.registry.get_entry( data_key=f"{self.table_name}:{k}:{row_index}", ) self.registry.set_entry( @@ -260,7 +259,7 @@ def deprecated_fetch_row(self, row_index: int) -> dict: self.logger.debug("Fetching row at index: " + str(row_index)) row = {} for c in self.columns: - data, revision = self.registry.get_entry(data_key=f"{self.table_name}:{c}:{row_index}") + data, _ = self.registry.get_entry(data_key=f"{self.table_name}:{c}:{row_index}") row[c] = data return row @@ -333,7 +332,7 @@ async def _fetch(self, condition: dict, n_rows: int, work_index: int, condition_ resp_data = await self.registry.aio_get_entry( data_key=f"{self.table_name}:{k}:{work_index}" ) - data, revision = resp_data[f"{self.table_name}:{k}:{work_index}"] + data, _ = resp_data[f"{self.table_name}:{k}:{work_index}"] if condition_func(condition, k, data, self.column_split): # The value at the column matches the condition keys_satisfy = True @@ -563,7 +562,7 @@ async def aio_set_entry(self, data_key: str, data: str, revision: int): """) - async def aio_get_entry(self, data_key: str, timeout: int = 30,) -> str: + async def aio_get_entry(self, data_key: str, *args, **kwargs) -> str: """ - Used aio requests to get data from skydb """