pipeline.src.flows.risk_factors
===============================

.. py:module:: pipeline.src.flows.risk_factors


Functions
---------

.. autoapisummary::

   pipeline.src.flows.risk_factors.extract_current_segments
   pipeline.src.flows.risk_factors.extract_recent_segments
   pipeline.src.flows.risk_factors.extract_usual_segments
   pipeline.src.flows.risk_factors.extract_vessels_with_current_vms_fishing_activity
   pipeline.src.flows.risk_factors.compute_profile_segments_risk_levels
   pipeline.src.flows.risk_factors.extract_control_anteriority
   pipeline.src.flows.risk_factors.merge
   pipeline.src.flows.risk_factors.compute_risk_factors
   pipeline.src.flows.risk_factors.load_risk_factors
   pipeline.src.flows.risk_factors.risk_factors_flow


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

.. py:function:: extract_current_segments()

.. py:function:: extract_recent_segments()

.. py:function:: extract_usual_segments()

.. py:function:: extract_vessels_with_current_vms_fishing_activity() -> set

.. py:function:: compute_profile_segments_risk_levels(profile_segments: pandas.DataFrame, segments: pandas.DataFrame, control_priorities_and_infringement_risk_levels: pandas.DataFrame, profile_type: src.entities.vessel_profiles.VesselProfileType) -> pandas.DataFrame

.. py:function:: extract_control_anteriority()

.. py:function:: merge(current_segments: pandas.DataFrame, recent_segments: pandas.DataFrame, usual_segments: pandas.DataFrame) -> pandas.DataFrame

.. py:function:: compute_risk_factors(merged_segments: pandas.DataFrame, control_anteriority: pandas.DataFrame, vessels_with_current_vms_fishing_activity: set)

.. py:function:: load_risk_factors(risk_factors: pandas.DataFrame)

   Load the output of ``compute_risk_factors`` task into ``risk_factors`` table.

   :param risk_factors: output of ``compute_risk_factors`` task.
   :type risk_factors: pd.DataFrame


.. py:function:: risk_factors_flow()