@@ -35,6 +35,7 @@ def _create_iceberg_table(
3535 index : bool = False ,
3636 data_source : str | None = None ,
3737 workgroup : str | None = None ,
38+ s3_output : str | None = None ,
3839 encryption : str | None = None ,
3940 kms_key : str | None = None ,
4041 boto3_session : boto3 .Session | None = None ,
@@ -73,6 +74,7 @@ def _create_iceberg_table(
7374 wg_config = wg_config ,
7475 database = database ,
7576 data_source = data_source ,
77+ s3_output = s3_output ,
7678 encryption = encryption ,
7779 kms_key = kms_key ,
7880 boto3_session = boto3_session ,
@@ -143,6 +145,7 @@ def _alter_iceberg_table(
143145 wg_config : _WorkGroupConfig ,
144146 data_source : str | None = None ,
145147 workgroup : str | None = None ,
148+ s3_output : str | None = None ,
146149 encryption : str | None = None ,
147150 kms_key : str | None = None ,
148151 boto3_session : boto3 .Session | None = None ,
@@ -174,6 +177,7 @@ def _alter_iceberg_table(
174177 wg_config = wg_config ,
175178 database = database ,
176179 data_source = data_source ,
180+ s3_output = s3_output ,
177181 encryption = encryption ,
178182 kms_key = kms_key ,
179183 boto3_session = boto3_session ,
@@ -400,6 +404,7 @@ def to_iceberg(
400404 index = index ,
401405 data_source = data_source ,
402406 workgroup = workgroup ,
407+ s3_output = s3_output ,
403408 encryption = encryption ,
404409 kms_key = kms_key ,
405410 boto3_session = boto3_session ,
@@ -441,6 +446,7 @@ def to_iceberg(
441446 wg_config = wg_config ,
442447 data_source = data_source ,
443448 workgroup = workgroup ,
449+ s3_output = s3_output ,
444450 encryption = encryption ,
445451 kms_key = kms_key ,
446452 boto3_session = boto3_session ,
0 commit comments