pipeline.src.shared_tasks.infrastructure
========================================

.. py:module:: pipeline.src.shared_tasks.infrastructure


Functions
---------

.. autoapisummary::

   pipeline.src.shared_tasks.infrastructure.get_table
   pipeline.src.shared_tasks.infrastructure.execute_statement


Module Contents
---------------

.. py:function:: get_table(table_name: str, schema: str = 'public', database: str = 'monitorfish_remote') -> sqlalchemy.Table

   Returns a `Table` representing the specified table.

   :param table_name: Name of the table
   :type table_name: str
   :param schema: Schema of the table. Defaults to "public".
   :type schema: str, optional
   :param database: Database of the table, can be 'monitorfish_remote'
                    or 'monitorfish_local'. Defaults to "monitorfish_remote".
   :type database: str, optional

   :returns: `sqlalchemy.Table` representing the specified table.
   :rtype: Table


.. py:function:: execute_statement(statement: sqlalchemy.Executable)

   Execute input statement on Monitorfish remote database

   :param statement: Statement to execute
   :type statement: Executable