pipeline.src.flows.missing_trip_numbers
=======================================

.. py:module:: pipeline.src.flows.missing_trip_numbers


Functions
---------

.. autoapisummary::

   pipeline.src.flows.missing_trip_numbers.reset_computed_trip_numbers
   pipeline.src.flows.missing_trip_numbers.extract_computed_trip_numbers
   pipeline.src.flows.missing_trip_numbers.load_computed_trip_numbers
   pipeline.src.flows.missing_trip_numbers.missing_trip_numbers_flow


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

.. py:function:: reset_computed_trip_numbers()

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

   Extract a computed `trip_number` for ERS messages of type 'DAT' that do not have a
   trip number.

   For each vessel and each year, a new trip is detected when a DEP or a LAN message
   occurs.

   :returns:

             Dataframe of computed trip numbers with id and
               trip_number columns
   :rtype: pd.DataFrame


.. py:function:: load_computed_trip_numbers(computed_trip_numbers: pandas.DataFrame)

   Updates the `logbook_reports` table. Computed trip numbers are added to the trip_number
   column of the table.

   :param computed_trip_numbers: output of extract_computed_trip_numbers.
                                 Dataframe of computed trip numbers with id and trip_number columns
   :type computed_trip_numbers: pd.DataFrame


.. py:function:: missing_trip_numbers_flow(reset_trip_numbers: bool = False)