diff --git a/etlhelper/etl.py b/etlhelper/etl.py index 113b22f..2833c28 100644 --- a/etlhelper/etl.py +++ b/etlhelper/etl.py @@ -49,7 +49,7 @@ def cursor(self): ... -Row = Iterable[Any] +Row = Sequence[Any] Chunk = list[Row] logger = logging.getLogger('etlhelper') @@ -229,7 +229,7 @@ def fetchall( def executemany( query: str, conn: Connection, - rows: list[tuple[Any]], + rows: Iterator[Row], transform: Optional[Callable[[Chunk], Chunk]] = None, on_error: Optional[Callable] = None, commit_chunks: bool = True,