pipeline.src.flows.position_alerts

Functions

extract_position_alerts(→ pandas.DataFrame)

to_position_alert_specifications(...)

get_alerts_that_must_run_now(...)

position_alerts_flow()

Module Contents

pipeline.src.flows.position_alerts.extract_position_alerts() → pandas.DataFrame[source]
pipeline.src.flows.position_alerts.to_position_alert_specifications(position_alerts: pandas.DataFrame) → List[src.entities.alerts.PositionAlertSpecification][source]
pipeline.src.flows.position_alerts.get_alerts_that_must_run_now(alert_specifications: List[src.entities.alerts.PositionAlertSpecification], now: datetime.datetime) → List[src.entities.alerts.PositionAlertSpecification][source]
pipeline.src.flows.position_alerts.position_alerts_flow()[source]