pipeline.src.flows.foreign_fmcs
===============================

.. py:module:: pipeline.src.flows.foreign_fmcs


Functions
---------

.. autoapisummary::

   pipeline.src.flows.foreign_fmcs.extract_foreign_fmcs_contacts
   pipeline.src.flows.foreign_fmcs.transform_foreign_fmcs_contacts
   pipeline.src.flows.foreign_fmcs.load_foreign_fmcs
   pipeline.src.flows.foreign_fmcs.foreign_fmcs_flow


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

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

   Extract foreign fmcs contact data from Poseidon.

   :returns: foreign fmcs contact data.
   :rtype: pd.DataFrame


.. py:function:: transform_foreign_fmcs_contacts(foreign_fmcs_contacts: pandas.DataFrame) -> pandas.DataFrame

   Remove `CNSP_SIP_DEPARTMENT_EMAIL` where present and aggregate countries' email addresses into arrays.

   :param foreign_fmcs_contacts: Extracted fmc data from Poseidon.
   :type foreign_fmcs_contacts: pd.DataFrame

   :returns: Transformed fmc data.
   :rtype: pd.DataFrame


.. py:function:: load_foreign_fmcs(foreign_fmcs)

.. py:function:: foreign_fmcs_flow(extract_foreign_fmcs_contacts_task=extract_foreign_fmcs_contacts)