@@ -1491,6 +1491,7 @@ def copy( # pylint: disable=too-many-arguments,too-many-locals
14911491 keep_files : bool = False ,
14921492 use_threads : Union [bool , int ] = True ,
14931493 lock : bool = False ,
1494+ commit_transaction : bool = True ,
14941495 sql_copy_extra_params : Optional [List [str ]] = None ,
14951496 boto3_session : Optional [boto3 .Session ] = None ,
14961497 s3_additional_kwargs : Optional [Dict [str , str ]] = None ,
@@ -1584,6 +1585,8 @@ def copy( # pylint: disable=too-many-arguments,too-many-locals
15841585 If integer is provided, specified number is used.
15851586 lock : bool
15861587 True to execute LOCK command inside the transaction to force serializable isolation.
1588+ commit_transaction : bool
1589+ Whether to commit the transaction. True by default.
15871590 sql_copy_extra_params : Optional[List[str]]
15881591 Additional copy parameters to pass to the command. For example: ["STATUPDATE ON"]
15891592 boto3_session : boto3.Session(), optional
@@ -1668,6 +1671,7 @@ def copy( # pylint: disable=too-many-arguments,too-many-locals
16681671 serialize_to_json = serialize_to_json ,
16691672 use_threads = use_threads ,
16701673 lock = lock ,
1674+ commit_transaction = commit_transaction ,
16711675 boto3_session = session ,
16721676 s3_additional_kwargs = s3_additional_kwargs ,
16731677 sql_copy_extra_params = sql_copy_extra_params ,
0 commit comments