Open
Description
The DbToDbHook
has a chunksize
parameter:
FastETL/fastetl/hooks/db_to_db_hook.py
Line 31 in d82c5c4
But the DbToDbOperator
does not:
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.
Activity