Executes redshift query and gets response for query when finished

Specifies style guidelines for pdf report and column formatting @return: dict, style guidelines

@param report: Report object @param paragraph: str, report paragraph that is being edited @param replace_dict: dict, specific elements t

Getting audit logs from S3 for the cluster from get_s3_logs and calling the pasrse_log() :param log_bucket: :param log_pre

Print presigned url for report of given replay @param bucket_url: str, S3 bucket location @param replay: str, replay id

Change DDL of self such that it has the same structure as other :param other: Resource implementation of same type a self :re

Creates a presigned url for a given object @param bucket_name: str, bucket name @param object_name: str, object name @return:

This is a wrapper around delete_objects for the boto3 S3 client. This call only allows a maximum of 1000 keys otherwise an Exception

Get ddl but adapt it to create a relation with different name but same structure :param ddl: ddl from admin.v_generate_tbl_ddl view

Get IDC group ID using AWS CLI get-group-id command with caching

Define the log format, with the option to prepend process and job/thread to each message

This function will calculate size of every folder inside the copy_replacement.csv @param copy_file_location: @return:

Get grants for each table using SHOW GRANTS command Returns a dictionary mapping (db_name, schema_name, table_name) to a list of (grantee, pr

Initialize logging to stdio

If query doesn't contain problem statements, saves it.

load a file from s3 or local. decode if the file should be interpreted as text rather than binary

* FILTERING FUNCTIONS: all have the same structure * @param {Object} item individual entry in collection * @return {boolean} whether item ma

This function parses the different logs and send it to the respective function :param log_file: filname(either connectionlog, useractivitylo

Parses the S3 list objects response into an iterator of entries.

Update logging to prepend process_id and / or job_id to all emitted logs

Retry adding to the queue indefinitely until it succeeds. This should only raise an exception and retry if the queue limit is hit.

Categorise bytes in GB,MB,TB @param bytes: @return: