def METHOD_NAME(connection: MagicMock, s3_writer: FireboltS3Writer) -> None:
    expected_sql = "DROP TABLE IF EXISTS ex_airbyte_raw_my_table"
    bucket_path = "dummy_bucket/airbyte_output/111_dummy-uuid/my_table"
    s3_writer.cleanup("my_table")
    connection.cursor.return_value.execute.assert_called_once_with(expected_sql)
    s3_writer.fs.delete_dir_contents.assert_called_once_with(bucket_path)