pipeline.src.flows.position_alerts
==================================

.. py:module:: pipeline.src.flows.position_alerts


Functions
---------

.. autoapisummary::

   pipeline.src.flows.position_alerts.extract_position_alerts
   pipeline.src.flows.position_alerts.to_position_alert_specifications
   pipeline.src.flows.position_alerts.get_alerts_that_must_run_now
   pipeline.src.flows.position_alerts.position_alerts_flow


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

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

.. py:function:: to_position_alert_specifications(position_alerts: pandas.DataFrame) -> List[src.entities.alerts.PositionAlertSpecification]

.. py:function:: get_alerts_that_must_run_now(alert_specifications: List[src.entities.alerts.PositionAlertSpecification], now: datetime.datetime) -> List[src.entities.alerts.PositionAlertSpecification]

.. py:function:: position_alerts_flow()