-
Notifications
You must be signed in to change notification settings - Fork 14.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
DbApiHook: add chunksize to get_pandas_df parameters #8468
Comments
There are a problem with the chunksize, because the get_pandas_df close the connection in the first call of the iterator[DataFrame] returned |
Hi @imorales-mosaico is there a workaround about |
Please @imorales-mosaico - open a new Feature/Bug request with a bit better description, rather than commenting on a closed ticket (you can add Relates to: #8464 in the description). |
(Or Ideally submit a PR fixing the problem immediately - if there is a problem). |
Description
The method "get_pandas_df" should be extended by the parameter "chunksize".
Use case / motivation
For the case that very large amounts of data are read, the "chunksize" is a good way to reduce the size of individual queries.
Links
airflow/airflow/hooks/dbapi_hook.py
Line 123 in f4faed6
https://github.com/pandas-dev/pandas/blob/0.25.x/pandas/io/sql.py#L344
The text was updated successfully, but these errors were encountered: