pipeline.src.flows.regulations
==============================

.. py:module:: pipeline.src.flows.regulations


Functions
---------

.. autoapisummary::

   pipeline.src.flows.regulations.extract_local_hashes
   pipeline.src.flows.regulations.extract_remote_hashes
   pipeline.src.flows.regulations.merge_hashes
   pipeline.src.flows.regulations.select_ids_to_update
   pipeline.src.flows.regulations.select_ids_to_delete
   pipeline.src.flows.regulations.update_required
   pipeline.src.flows.regulations.delete_required
   pipeline.src.flows.regulations.delete
   pipeline.src.flows.regulations.extract_new_regulations
   pipeline.src.flows.regulations.load_new_regulations
   pipeline.src.flows.regulations.regulations_flow


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

.. py:function:: extract_local_hashes() -> pandas.DataFrame

.. py:function:: extract_remote_hashes() -> pandas.DataFrame

.. py:function:: merge_hashes(local_hashes: pandas.DataFrame, remote_hashes: pandas.DataFrame) -> pandas.DataFrame

.. py:function:: select_ids_to_update(hashes: pandas.DataFrame) -> set

.. py:function:: select_ids_to_delete(hashes: pandas.DataFrame) -> set

.. py:function:: update_required(ids_to_update: set) -> bool

.. py:function:: delete_required(ids_to_delete: set) -> bool

.. py:function:: delete(ids_to_delete: set)

.. py:function:: extract_new_regulations(ids_to_update: set) -> pandas.DataFrame

.. py:function:: load_new_regulations(new_regulations: pandas.DataFrame)

   Load the output of ``extract_rows_to_update`` task into ``regulations``
   table.

   :param new_regulations: output of ``extract_rows_to_update`` task.
   :type new_regulations: pd.DataFrame


.. py:function:: regulations_flow()