pipeline.src.shared_tasks.infrastructure

Functions

get_table(→ sqlalchemy.Table)	Returns a Table representing the specified table.
execute_statement(statement)	Execute input statement on Monitorfish remote database

Module Contents

pipeline.src.shared_tasks.infrastructure.get_table(table_name: str, schema: str = 'public', database: str = 'monitorfish_remote') → sqlalchemy.Table

Returns a Table representing the specified table.

Parameters:

• table_name (str) – Name of the table

• schema (str, optional) – Schema of the table. Defaults to “public”.

• database (str, optional) – Database of the table, can be ‘monitorfish_remote’ or ‘monitorfish_local’. Defaults to “monitorfish_remote”.

Returns:

sqlalchemy.Table representing the specified table.

Return type:

Table

pipeline.src.shared_tasks.infrastructure.execute_statement(statement: sqlalchemy.Executable)

Execute input statement on Monitorfish remote database

Parameters:

statement (Executable) – Statement to execute