Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
jond01 committed Sep 11, 2024
1 parent 368fc69 commit 5f28f58
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion storey/targets.py
Original file line number Diff line number Diff line change
Expand Up @@ -978,7 +978,10 @@ def _raw_value_to_value(value):
def _get_batch_values(
cls, reg_cols_schema: list[tuple[str, Callable[[list], "taosws.PyColumnView"]]], batch: list[dict]
) -> list:
return [col_func([cls._raw_value_to_value(event.get(col_name)) for event in batch]) for col_name, col_func in reg_cols_schema]
return [
col_func([cls._raw_value_to_value(event.get(col_name)) for event in batch])
for col_name, col_func in reg_cols_schema
]

async def _emit(self, batch: list[dict], batch_key: str, batch_time, batch_events, last_event_time=None):
tags_schema, reg_cols_schema = self._get_table_schema(self._table or self._supertable)
Expand Down

0 comments on commit 5f28f58

Please sign in to comment.