Skip to content

pass sql_copy_extra_params to _copy for redshift.copy() #1256

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.

Sign up for GitHub

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

Merged
merged 5 commits into from
Apr 7, 2022
Merged

pass sql_copy_extra_params to _copy for redshift.copy() #1256

Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
bba0e77
pass sql_copy_extra_params to _copy for redshift.copy()
Apr 5, 2022
545aaba
bump vers
Apr 5, 2022
b2b3c81
Revert "bump vers"
Apr 5, 2022
89a3ba1
Missing docs
jaidisido Apr 6, 2022
ced6ffb
Merge branch 'main' into fx-pass-sql-params
jaidisido Apr 7, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions awswrangler/redshift.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1297,6 +1297,8 @@ def copy_from_files( # pylint: disable=too-many-locals,too-many-arguments
Whether to commit the transaction. True by default.
manifest: bool
If set to true path argument accepts a S3 uri to a manifest file.
sql_copy_extra_params: Optional[List[str]]
Additional copy parameters to pass to the command. For example: ["STATUPDATE ON"]
boto3_session : boto3.Session(), optional
Boto3 Session. The default boto3 session will be used if boto3_session receive None.
s3_additional_kwargs:
Expand Down Expand Up @@ -1408,6 +1410,7 @@ def copy( # pylint: disable=too-many-arguments
keep_files: bool = False,
use_threads: Union[bool, int] = True,
lock: bool = False,
sql_copy_extra_params: Optional[List[str]] = None,
boto3_session: Optional[boto3.Session] = None,
s3_additional_kwargs: Optional[Dict[str, str]] = None,
max_rows_by_file: Optional[int] = 10_000_000,
Expand Down Expand Up @@ -1498,6 +1501,8 @@ def copy( # pylint: disable=too-many-arguments
If integer is provided, specified number is used.
lock : bool
True to execute LOCK command inside the transaction to force serializable isolation.
sql_copy_extra_params: Optional[List[str]]
Additional copy parameters to pass to the command. For example: ["STATUPDATE ON"]
boto3_session : boto3.Session(), optional
Boto3 Session. The default boto3 session will be used if boto3_session receive None.
s3_additional_kwargs:
Expand Down Expand Up @@ -1573,6 +1578,7 @@ def copy( # pylint: disable=too-many-arguments
lock=lock,
boto3_session=session,
s3_additional_kwargs=s3_additional_kwargs,
sql_copy_extra_params=sql_copy_extra_params,
)
finally:
if keep_files is False:
Expand Down