-
Notifications
You must be signed in to change notification settings - Fork 9
Open
Labels
enhancementNew feature or requestNew feature or request
Description
The DbToDbHook
has a chunksize
parameter:
FastETL/fastetl/hooks/db_to_db_hook.py
Line 31 in d82c5c4
chunksize: int = 1000, |
But the DbToDbOperator
does not:
def __init__(self, |
So it is not currently possible to define a chunk size in a DAG using the operator.
A chunksize
argument to the operator so that it can be used. The code should pass it on to the hook if used.
edulauer
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or request