astronomer.providers.amazon.aws.hooks.redshift_sql

Module Contents

Classes

RedshiftSQLHookAsync

RedshiftSQL async hook inherits from RedshiftDataHook to interact with AWS redshift cluster database
class astronomer.providers.amazon.aws.hooks.redshift_sql.RedshiftSQLHookAsync(*args, poll_interval=0, **kwargs)[source]

Bases: astronomer.providers.amazon.aws.hooks.redshift_data.RedshiftDataHook

RedshiftSQL async hook inherits from RedshiftDataHook to interact with AWS redshift cluster database

async get_query_status(query_ids)[source]

Async function to get the Query status by query Ids, this function takes list of query_ids make async connection to redshift data to get the query status by query id returns the query status.

Parameters:

query_ids (List[str]) – list of query ids

async is_still_running(qid)[source]

Async function to whether the query is still running or in “PICKED”, “STARTED”, “SUBMITTED” state and returns True else return False