(
redshift_data_client,
cluster_id: str,
workgroup: str,
database: str,
user: str,
table_name: str,
)
| 269 | |
| 270 | |
| 271 | def delete_redshift_table( |
| 272 | redshift_data_client, |
| 273 | cluster_id: str, |
| 274 | workgroup: str, |
| 275 | database: str, |
| 276 | user: str, |
| 277 | table_name: str, |
| 278 | ): |
| 279 | drop_query = f"DROP {table_name} IF EXISTS" |
| 280 | execute_redshift_statement( |
| 281 | redshift_data_client, |
| 282 | cluster_id, |
| 283 | workgroup, |
| 284 | database, |
| 285 | user, |
| 286 | drop_query, |
| 287 | ) |
| 288 | |
| 289 | |
| 290 | def upload_arrow_table_to_redshift( |
nothing calls this directly
no test coverage detected