pipeline.src.flows.risk_elements
================================

.. py:module:: pipeline.src.flows.risk_elements


Functions
---------

.. autoapisummary::

   pipeline.src.flows.risk_elements.extract_total_trips
   pipeline.src.flows.risk_elements.extract_vms_vessels
   pipeline.src.flows.risk_elements.extract_trips_subject_to_pno
   pipeline.src.flows.risk_elements.extract_rtps
   pipeline.src.flows.risk_elements.extract_logbook_pnos
   pipeline.src.flows.risk_elements.extract_manual_pnos
   pipeline.src.flows.risk_elements.evaluate_trips_pnos
   pipeline.src.flows.risk_elements.compute_pno_mr_trips_per_vessel
   pipeline.src.flows.risk_elements.extract_occurrences
   pipeline.src.flows.risk_elements.extract_compliant_trips
   pipeline.src.flows.risk_elements.compute_occurrences_vessels_risk_elements
   pipeline.src.flows.risk_elements.compute_vessels_risk_elements
   pipeline.src.flows.risk_elements.load_vessels_risk_elements
   pipeline.src.flows.risk_elements.risk_elements_flow


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

.. py:function:: extract_total_trips(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_vms_vessels(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_trips_subject_to_pno(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_rtps(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_logbook_pnos(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_manual_pnos(from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: evaluate_trips_pnos(trips_subject_to_pno: pandas.DataFrame, rtps: pandas.DataFrame, manual_pnos: pandas.DataFrame, logbook_pnos: pandas.DataFrame) -> pandas.DataFrame

.. py:function:: compute_pno_mr_trips_per_vessel(evaluated_trips_pnos: pandas.DataFrame) -> Tuple[pandas.DataFrame, pandas.DataFrame]

.. py:function:: extract_occurrences(risk_element: src.entities.risk_elements.RiskElement, from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_compliant_trips(risk_element: src.entities.risk_elements.RiskElement, from_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: compute_occurrences_vessels_risk_elements(vessels: pandas.DataFrame, occurrences: pandas.DataFrame, risk_element: src.entities.risk_elements.RiskElement)

.. py:function:: compute_vessels_risk_elements(total_trips: pandas.DataFrame, compliant_trips: pandas.DataFrame, risk_element: src.entities.risk_elements.RiskElement)

.. py:function:: load_vessels_risk_elements(vessels_risk_elements: pandas.DataFrame)

.. py:function:: risk_elements_flow()