pipeline.src.flows.current_segments
===================================

.. py:module:: pipeline.src.flows.current_segments


Functions
---------

.. autoapisummary::

   pipeline.src.flows.current_segments.extract_current_catches
   pipeline.src.flows.current_segments.extract_last_positions
   pipeline.src.flows.current_segments.compute_current_segments
   pipeline.src.flows.current_segments.load_current_segments
   pipeline.src.flows.current_segments.current_segments_flow


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

.. py:function:: extract_current_catches(number_of_days: int) -> pandas.DataFrame

.. py:function:: extract_last_positions()

.. py:function:: compute_current_segments(current_catches, segments, last_positions, control_priorities_and_infringement_risk_levels)

.. py:function:: load_current_segments(vessels_segments)

.. py:function:: current_segments_flow(number_of_days: int = 90)