Index

_

__post_init__() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) (pipeline.src.entities.pnos.PnoCatch method) (pipeline.src.entities.pnos.PnoToRender method) _df_to_dict() (in module pipeline.src.flows.activity_visualizations) _find() (in module pipeline.src.parsers.flux.sales_parsers)

_findall() (in module pipeline.src.parsers.flux.sales_parsers) _get() (in module pipeline.src.parsers.flux.sales_parsers) _make_datetime() (in module pipeline.src.parsers.flux.sales_parsers) _normalize_data() (in module pipeline.src.flows.activity_visualizations) _repr_html_() (in module pipeline.src.flows.activity_visualizations)

A

ACS (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) actions_max_datetime_utc (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) actions_min_datetime_utc (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) ACTIVATED (pipeline.src.entities.beacon_malfunctions.BeaconStatus attribute) ACTIVITY_DETECTED (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) activity_visualizations_flow() (in module pipeline.src.flows.activity_visualizations) add_article_id() (in module pipeline.src.flows.regulations_checkup) add_depth() (in module pipeline.src.shared_tasks.positions) add_latest_port_facade() (in module pipeline.src.flows.vessel_profiles) add_unknown_vessel() (in module pipeline.src.flows.vessels) add_vessel_id() (in module pipeline.src.shared_tasks.vessels) add_vessel_identifier() (in module pipeline.src.shared_tasks.positions) add_vessels_columns() (in module pipeline.src.shared_tasks.vessels) additional_addressees (pipeline.src.entities.pnos.RenderedPno attribute) address_or_number (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationAddressee attribute) admin_areas_flow() (in module pipeline.src.flows.admin_areas) AdminAreasSpecification (class in pipeline.src.entities.alerts) AdminAreasSpecWithTable (class in pipeline.src.entities.alerts) administration (pipeline.src.entities.control_units.ControlUnit attribute) administrative_areas (pipeline.src.entities.alerts.PositionAlertSpecification attribute) AdministrativeAreaType (class in pipeline.src.entities.alerts) AIR (pipeline.src.entities.missions.MissionType attribute) AIR_CONTROL (pipeline.src.entities.missions.MissionActionType attribute) air_controls (pipeline.src.entities.control_units.ControlUnitActions attribute) AIR_SURVEILLANCE (pipeline.src.entities.missions.MissionActionType attribute)

air_surveillances (pipeline.src.entities.control_units.ControlUnitActions attribute) AlertType (class in pipeline.src.entities.alerts) allocate_segments_to_catches() (in module pipeline.src.helpers.segments) anchorages_compute_flow() (in module pipeline.src.flows.anchorages) anchorages_flow() (in module pipeline.src.flows.anchorages) api_url() (in module pipeline.src.shared_tasks.datagouv) archive_reporting() (in module pipeline.src.shared_tasks.alerts) ARCHIVED (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) AREA_ENTRY (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) AREA_EXIT (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) area_type (pipeline.src.entities.alerts.AdminAreasSpecWithTable attribute) areas (pipeline.src.entities.alerts.AdminAreasSpecification attribute) (pipeline.src.entities.alerts.AdminAreasSpecWithTable attribute) AreasTableMetadata (class in pipeline.src.entities.alerts) areaType (pipeline.src.entities.alerts.AdminAreasSpecification attribute) array_equals_row_on_window() (in module pipeline.src.processing) ARRIVAL (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) assert_equal() (pipeline.src.entities.pnos.PreRenderedPno static method) assert_last_positions_flow_health() (in module pipeline.src.shared_tasks.healthcheck) assert_logbook_health() (in module pipeline.src.shared_tasks.healthcheck) assert_positions_received_by_api_health() (in module pipeline.src.shared_tasks.healthcheck) AT_PORT (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) AT_QUAY (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) AT_SEA (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) attribute_addressees() (in module pipeline.src.flows.distribute_pnos)

B

back_propagate_ones() (in module pipeline.src.processing) base64_decode() (in module pipeline.src.parsers.flux.flux) batch_parse() (in module pipeline.src.parsers.ers.ers) (in module pipeline.src.parsers.flux.flux) BEACON_DEACTIVATED_OR_UNEQUIPPED (pipeline.src.entities.beacon_malfunctions.EndOfMalfunctionReason attribute) beacon_malfunction_id (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) beacon_malfunction_to_notify (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionMessageToSend attribute) beacon_number (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) BeaconMalfunctionMessageToSend (class in pipeline.src.entities.beacon_malfunctions)

BeaconMalfunctionNotification (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionNotificationAddressee (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionNotificationRecipientFunction (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionNotificationType (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionStage (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionToNotify (class in pipeline.src.entities.beacon_malfunctions) BeaconMalfunctionVesselStatus (class in pipeline.src.entities.beacon_malfunctions) beacons_flow() (in module pipeline.src.flows.beacons) BeaconStatus (class in pipeline.src.entities.beacon_malfunctions) bft_summary (pipeline.src.entities.pnos.PreRenderedPno attribute)

C

catch_onboard (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) cfr (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) CLA_CM (pipeline.src.entities.risk_elements.RiskElement attribute) clean() (in module pipeline.src.flows.sales_and_logbook) clean_circabc() (in module pipeline.src.flows.ports) clean_fao_areas() (in module pipeline.src.flows.ports) clean_infractions() (in module pipeline.src.flows.infractions) clean_ports() (in module pipeline.src.flows.ports) clean_unece() (in module pipeline.src.flows.ports) clean_vessels() (in module pipeline.src.flows.vessels) CLOSED_AREA (pipeline.src.entities.missions.FlightGoal attribute) coalesce() (in module pipeline.src.processing) code (pipeline.src.entities.fleet_segments.FishingGear attribute) (pipeline.src.entities.fleet_segments.FleetSegment attribute) combine_columns_into_value() (in module pipeline.src.flows.ports) comments (pipeline.src.entities.missions.Infraction attribute) communication_means (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionMessageToSend attribute) (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.pnos.PnoAddressee attribute) (pipeline.src.entities.pnos.PnoToSend attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) CommunicationMeans (class in pipeline.src.entities.communication_means) complete_pro() (in module pipeline.src.parsers.flux.childless_parsers) complete_ras() (in module pipeline.src.parsers.flux.childless_parsers) compute_control_dates_coefficients() (in module pipeline.src.flows.control_anteriority) compute_control_ranks_coefficients() (in module pipeline.src.flows.control_anteriority) compute_control_rate_risk_factors() (in module pipeline.src.flows.control_anteriority) compute_control_statistics() (in module pipeline.src.flows.control_anteriority) compute_controls_facade() (in module pipeline.src.flows.controls) compute_controls_fao_areas() (in module pipeline.src.flows.controls) compute_controls_segments() (in module pipeline.src.flows.recompute_controls_segments) compute_current_segments() (in module pipeline.src.flows.current_segments) compute_emission_period() (in module pipeline.src.flows.last_positions) compute_infraction_rate_risk_factors() (in module pipeline.src.flows.control_anteriority) compute_movement_metrics() (in module pipeline.src.helpers.spatial) compute_occurrences_vessels_risk_elements() (in module pipeline.src.flows.risk_elements) compute_pno_mr_trips_per_vessel() (in module pipeline.src.flows.risk_elements) compute_pno_risk_factors() (in module pipeline.src.flows.enrich_logbook) compute_pno_segments() (in module pipeline.src.flows.enrich_logbook)

compute_pno_types() (in module pipeline.src.flows.enrich_logbook) compute_ports_zones() (in module pipeline.src.flows.ports) compute_profile_segments_risk_levels() (in module pipeline.src.flows.risk_factors) compute_risk_factors() (in module pipeline.src.flows.risk_factors) compute_vessels_risk_elements() (in module pipeline.src.flows.risk_elements) concat() (in module pipeline.src.flows.missing_far_alerts) concat_merge_vessels() (in module pipeline.src.flows.vessels) concatenate() (in module pipeline.src.flows.last_positions) concatenate_columns() (in module pipeline.src.processing) concatenate_values() (in module pipeline.src.processing) concurrency_limit (pipeline.src.deployments.FlowAndSchedules attribute) control_anteriority_flow() (in module pipeline.src.flows.control_anteriority) control_rate_bins (in module pipeline.src.flows.control_anteriority) control_rate_bins_risk_factors (in module pipeline.src.flows.control_anteriority) control_unit (pipeline.src.entities.control_units.ControlUnitActions attribute) control_unit_actions_list_to_df() (in module pipeline.src.flows.email_actions_to_units) control_unit_id (pipeline.src.entities.control_units.ControlUnit attribute) (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) control_unit_name (pipeline.src.entities.control_units.ControlUnit attribute) (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) control_units (pipeline.src.entities.pnos.RenderedPno attribute) control_units_flow() (in module pipeline.src.flows.control_units) controls_flow() (in module pipeline.src.flows.controls) controls_open_data_flow() (in module pipeline.src.flows.controls_open_data) ControlUnit (class in pipeline.src.entities.control_units) ControlUnitActions (class in pipeline.src.entities.control_units) ControlUnitActionsSentMessage (class in pipeline.src.entities.control_units) coordinate_to_dms() (in module pipeline.src.helpers.spatial) create_data_frame_to_load() (in module pipeline.src.flows.activity_visualizations) create_datawarehouse_client() (in module pipeline.src.db_config) create_email() (in module pipeline.src.flows.distribute_pnos) (in module pipeline.src.flows.email_actions_to_units) (in module pipeline.src.flows.notify_beacon_malfunctions) create_engine() (in module pipeline.src.db_config) create_fax() (in module pipeline.src.flows.notify_beacon_malfunctions) create_fax_email() (in module pipeline.src.helpers.emails) create_html_email() (in module pipeline.src.helpers.emails) create_message() (in module pipeline.src.flows.regulations_checkup) create_sms() (in module pipeline.src.flows.distribute_pnos) (in module pipeline.src.flows.notify_beacon_malfunctions) create_sms_email() (in module pipeline.src.helpers.emails) current_segments_flow() (in module pipeline.src.flows.current_segments)

D

data_to_json() (in module pipeline.src.flows.activity_visualizations) DataDomain (class in pipeline.src.entities.data_exchange_standards) date_last_position_received_by_api (pipeline.src.entities.monitorfish_healthcheck.MonitorfishHealthcheck attribute) date_last_position_updated_by_prefect (pipeline.src.entities.monitorfish_healthcheck.MonitorfishHealthcheck attribute) date_logbook_message_received (pipeline.src.entities.monitorfish_healthcheck.MonitorfishHealthcheck attribute) date_time_utc (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) date_trunc() (in module pipeline.src.shared_tasks.dates) DAY (pipeline.src.shared_tasks.dates.TimeUnit attribute) db_env (in module pipeline.src.db_config) DEACTIVATED (pipeline.src.entities.beacon_malfunctions.BeaconStatus attribute) DECLARATION (pipeline.src.parsers.flux.flux.FluxFAReportDocumentType attribute) default_concurrency_limit() (in module pipeline.src.deployments) default_log_parser() (in module pipeline.src.parsers.ers.log_parsers) delete() (in module pipeline.src.flows.regulations) (in module pipeline.src.utils) delete_required() (in module pipeline.src.flows.regulations) delete_rows() (in module pipeline.src.generic_tasks) (in module pipeline.src.utils)

DEPARTURE (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) deployment (in module pipeline.src.deployments) deployments (in module pipeline.src.deployments) description (pipeline.src.entities.alerts.PositionAlertSpecification attribute) detect_fishing_activity() (in module pipeline.src.helpers.spatial) df_to_dict_series() (in module pipeline.src.processing) df_values_to_json() (in module pipeline.src.processing) df_values_to_psql_arrays() (in module pipeline.src.processing) DISCARD (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) DISTANCE_TO_SHORE (pipeline.src.entities.alerts.AdministrativeAreaType attribute) distribute_pnos_flow() (in module pipeline.src.flows.distribute_pnos) district_codes (pipeline.src.entities.alerts.PositionAlertSpecification attribute) districts_flow() (in module pipeline.src.flows.districts) drop_duplicates() (in module pipeline.src.flows.last_positions) drop_duplicates_by_decreasing_priority() (in module pipeline.src.processing) drop_rows_already_in_table() (in module pipeline.src.processing) drop_unchanged_new_last_positions() (in module pipeline.src.flows.last_positions) duration_in_days (pipeline.src.entities.vessel_profiles.VesselProfileType property)

E

ECY (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) EEZ_AREA (pipeline.src.entities.alerts.AdministrativeAreaType attribute) EMAIL (pipeline.src.entities.communication_means.CommunicationMeans attribute) email_actions_to_units_flow() (in module pipeline.src.flows.email_actions_to_units) email_address (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) email_address_or_number (pipeline.src.entities.pnos.PnoAddressee attribute) emails (pipeline.src.entities.control_units.ControlUnit attribute) end (pipeline.src.helpers.dates.Period attribute) END_OF_MALFUNCTION (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) EndOfMalfunctionReason (class in pipeline.src.entities.beacon_malfunctions) enrich_logbook_flow() (in module pipeline.src.flows.enrich_logbook) enrich_positions() (in module pipeline.src.helpers.spatial) enrich_positions_by_vessel() (in module pipeline.src.flows.enrich_positions) enrich_positions_flow() (in module pipeline.src.flows.enrich_positions) error_code (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) ERROR_DIRECTORY (in module pipeline.src.flows.sales_and_logbook) error_message (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) error_reason (pipeline.src.entities.alerts.PositionAlertSpecification attribute) ERS (pipeline.src.entities.data_exchange_standards.TransmissionFormat attribute) ERS3_ACK_JBE (pipeline.src.entities.data_exchange_standards.ZippedFileType attribute) ERS3_JBE (pipeline.src.entities.data_exchange_standards.ZippedFileType attribute) ERS3_NVE (pipeline.src.entities.data_exchange_standards.ZippedFileType attribute) ERSParsingError estimate_current_position() (in module pipeline.src.helpers.spatial) estimate_current_positions() (in module pipeline.src.flows.last_positions) evaluate_trips_pnos() (in module pipeline.src.flows.risk_elements) execute_prior_notification_attachments_query() (in module pipeline.src.flows.distribute_pnos) execute_statement() (in module pipeline.src.shared_tasks.infrastructure) explode_dicts() (in module pipeline.src.processing) explode_lists_of_dicts() (in module pipeline.src.processing) export_isscaap_codes() (in module pipeline.src.flows.isscaap_codes) export_species() (in module pipeline.src.flows.export_species) export_species_flow() (in module pipeline.src.flows.export_species) external_identification (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) extract() (in module pipeline.src.generic_tasks) extract_1241_eaux_occidentales_australes_areas() (in module pipeline.src.flows.admin_areas) extract_1241_eaux_occidentales_septentrionales_areas() (in module pipeline.src.flows.admin_areas) extract_1241_eaux_union_dans_oi_et_atl_ouest_areas() (in module pipeline.src.flows.admin_areas) extract_1241_mer_baltique_areas() (in module pipeline.src.flows.admin_areas) extract_1241_mer_celtique_areas() (in module pipeline.src.flows.admin_areas) extract_1241_mer_du_nord_areas() (in module pipeline.src.flows.admin_areas) extract_1241_mer_mediterranee_areas() (in module pipeline.src.flows.admin_areas) extract_1241_mer_noire_areas() (in module pipeline.src.flows.admin_areas) extract_12_miles_areas() (in module pipeline.src.flows.admin_areas) extract_2025_segments() (in module pipeline.src.flows.init_2025_segments) extract_3_miles_areas() (in module pipeline.src.flows.admin_areas) extract_6_miles_areas() (in module pipeline.src.flows.admin_areas) extract_active_ports_locodes() (in module pipeline.src.flows.ports) extract_active_reportings() (in module pipeline.src.shared_tasks.alerts) extract_activity_overview_data() (in module pipeline.src.flows.activity_visualizations) extract_administrations() (in module pipeline.src.flows.control_units) extract_administre_nationalities() (in module pipeline.src.flows.vessels) extract_aem_areas() (in module pipeline.src.flows.admin_areas) extract_ais_anchorage_coordinates() (in module pipeline.src.flows.anchorages) extract_ais_last_positions() (in module pipeline.src.flows.last_positions) extract_all_segments() (in module pipeline.src.shared_tasks.segments) extract_beacon_malfunctions() (in module pipeline.src.flows.last_positions) extract_beacons() (in module pipeline.src.flows.beacons) extract_brexit_areas() (in module pipeline.src.flows.admin_areas) extract_catch_controls() (in module pipeline.src.flows.controls) extract_cgpm_areas() (in module pipeline.src.flows.admin_areas) extract_cgpm_statistical_rectangles_areas() (in module pipeline.src.flows.admin_areas) extract_circabc_locations() (in module pipeline.src.flows.ports) extract_circabc_ports() (in module pipeline.src.flows.ports) extract_compliant_trips() (in module pipeline.src.flows.risk_elements) extract_computed_trip_numbers() (in module pipeline.src.flows.missing_trip_numbers) extract_control_anteriority() (in module pipeline.src.flows.enrich_logbook) (in module pipeline.src.flows.risk_factors) extract_control_charters() (in module pipeline.src.flows.vessels) extract_control_ports_locodes() (in module pipeline.src.flows.anchorages) extract_control_priorities_and_infringement_risk_levels() (in module pipeline.src.shared_tasks.segments) extract_control_units() (in module pipeline.src.flows.control_units) extract_controls() (in module pipeline.src.flows.controls) extract_controls_catches() (in module pipeline.src.flows.recompute_controls_segments) extract_controls_open_data() (in module pipeline.src.flows.controls_open_data) extract_cormoran_areas() (in module pipeline.src.flows.admin_areas) extract_current_catches() (in module pipeline.src.flows.current_segments) extract_current_risk_factors() (in module pipeline.src.shared_tasks.risk_factors) extract_current_segments() (in module pipeline.src.flows.risk_factors) extract_datagouv_anchorages() (in module pipeline.src.flows.anchorages) extract_departments_areas() (in module pipeline.src.flows.admin_areas) extract_districts() (in module pipeline.src.flows.districts) extract_eez_areas() (in module pipeline.src.flows.admin_areas) extract_effort_zones_areas() (in module pipeline.src.flows.admin_areas) extract_enrich_load() (in module pipeline.src.flows.enrich_positions) extract_enrich_load_logbook() (in module pipeline.src.flows.enrich_logbook) extract_ers_ports_locodes() (in module pipeline.src.flows.anchorages) extract_eu_vessels() (in module pipeline.src.flows.vessels) extract_facade_areas() (in module pipeline.src.flows.facade_areas) (in module pipeline.src.shared_tasks.facades) extract_facade_email_addresses() (in module pipeline.src.flows.distribute_pnos) extract_facades_zee_fr_shom() (in module pipeline.src.flows.admin_areas) extract_fao_areas() (in module pipeline.src.flows.controls) (in module pipeline.src.flows.fao_areas) extract_fao_ccamlr_areas() (in module pipeline.src.flows.admin_areas) extract_fao_iccat_areas() (in module pipeline.src.flows.admin_areas) extract_fao_iotc_areas() (in module pipeline.src.flows.admin_areas) extract_fao_siofa_areas() (in module pipeline.src.flows.admin_areas) extract_fishing_gear_codes() (in module pipeline.src.flows.fishing_gear_codes) extract_fishing_gear_codes_groups() (in module pipeline.src.flows.fishing_gear_codes) extract_fishing_gear_names() (in module pipeline.src.flows.distribute_pnos) extract_fishing_infraction_natinfs() (in module pipeline.src.flows.control_anteriority) extract_fleet_segments_open_data() (in module pipeline.src.flows.controls_open_data)

extract_foreign_fmcs_contacts() (in module pipeline.src.flows.foreign_fmcs) extract_french_vessels() (in module pipeline.src.flows.vessels) extract_french_vessels_navigation_licences() (in module pipeline.src.flows.vessels) extract_gear_onboard() (in module pipeline.src.flows.vessel_profiles) extract_infraction_threat_characterization() (in module pipeline.src.flows.init_infraction_threat_characterization) extract_infractions() (in module pipeline.src.flows.infractions) extract_infringement_risk_levels() (in module pipeline.src.flows.enrich_logbook) extract_isr() (in module pipeline.src.flows.init_infraction_threat_characterization) extract_isscaap_codes_pdf() (in module pipeline.src.flows.isscaap_codes) extract_isscaap_groups() (in module pipeline.src.flows.export_species) extract_known_malfunctions() (in module pipeline.src.flows.update_beacon_malfunctions) extract_land_areas() (in module pipeline.src.flows.admin_areas) extract_last_positions() (in module pipeline.src.flows.current_segments) (in module pipeline.src.flows.update_beacon_malfunctions) extract_last_years_controls() (in module pipeline.src.flows.control_anteriority) extract_latest_port_profiles() (in module pipeline.src.flows.vessel_profiles) extract_legipeche_regulations() (in module pipeline.src.flows.regulations_checkup) extract_local_hashes() (in module pipeline.src.flows.regulations) extract_local_ports() (in module pipeline.src.flows.ports) extract_logbook_pnos() (in module pipeline.src.flows.risk_elements) extract_malfunctions_to_notify() (in module pipeline.src.flows.notify_beacon_malfunctions) extract_manual_anchorages_coordinates() (in module pipeline.src.flows.anchorages) extract_manual_pnos() (in module pipeline.src.flows.risk_elements) extract_missing_deps() (in module pipeline.src.flows.missing_dep_alerts) extract_mission_actions() (in module pipeline.src.flows.email_actions_to_units) extract_missions() (in module pipeline.src.flows.missions) extract_missions_control_units() (in module pipeline.src.flows.missions) extract_monitorfish_regulations() (in module pipeline.src.flows.regulations_checkup) extract_n_miles_to_shore_areas() (in module pipeline.src.flows.admin_areas) extract_nafo_regulatory_area() (in module pipeline.src.flows.admin_areas) extract_navigation_category_five_areas() (in module pipeline.src.flows.admin_areas) extract_navigation_category_four_areas() (in module pipeline.src.flows.admin_areas) extract_navigation_category_three_areas() (in module pipeline.src.flows.admin_areas) extract_navigation_category_two_areas() (in module pipeline.src.flows.admin_areas) extract_neafc_regulatory_area() (in module pipeline.src.flows.admin_areas) extract_new_regulations() (in module pipeline.src.flows.regulations) extract_non_archived_reportings_ids_of_type() (in module pipeline.src.shared_tasks.alerts) extract_non_eu_vessels() (in module pipeline.src.flows.vessels) extract_occurrences() (in module pipeline.src.flows.risk_elements) extract_pending_alerts() (in module pipeline.src.flows.last_positions) extract_pending_alerts_ids_of_type() (in module pipeline.src.shared_tasks.alerts) extract_pno_catches() (in module pipeline.src.flows.enrich_logbook) extract_pno_extra_subscriptions() (in module pipeline.src.flows.distribute_pnos) extract_pno_trips_period() (in module pipeline.src.flows.enrich_logbook) extract_pno_type_rules() (in module pipeline.src.flows.init_pno_types) extract_pno_types() (in module pipeline.src.flows.enrich_logbook) (in module pipeline.src.flows.init_pno_types) extract_pno_units_ports_and_segments_subscriptions() (in module pipeline.src.shared_tasks.pnos) extract_pno_units_targeting_vessels() (in module pipeline.src.shared_tasks.pnos) extract_pnos_to_generate() (in module pipeline.src.flows.distribute_pnos) extract_port_codes() (in module pipeline.src.flows.ports) extract_port_profiles() (in module pipeline.src.flows.vessel_profiles) extract_ports() (in module pipeline.src.flows.anchorages) (in module pipeline.src.flows.controls) extract_ports_facade() (in module pipeline.src.flows.vessel_profiles) extract_position_alerts() (in module pipeline.src.flows.position_alerts) extract_positions() (in module pipeline.src.flows.enrich_positions) extract_previous_vms_last_positions() (in module pipeline.src.flows.last_positions) extract_profiles() (in module pipeline.src.flows.vessel_profiles) extract_recent_segments() (in module pipeline.src.flows.risk_factors) extract_rectangles_stat_areas() (in module pipeline.src.flows.admin_areas) extract_regulations_open_data() (in module pipeline.src.flows.regulations_open_data) extract_remote_hashes() (in module pipeline.src.flows.regulations) extract_reportings() (in module pipeline.src.flows.last_positions) extract_risk_elements() (in module pipeline.src.flows.init_infraction_threat_characterization) extract_risk_factors() (in module pipeline.src.flows.last_positions) extract_rtps() (in module pipeline.src.flows.risk_elements) extract_saltwater_limit_areas() (in module pipeline.src.flows.admin_areas) extract_satellite_operators() (in module pipeline.src.flows.beacons) extract_satellite_operators_statuses() (in module pipeline.src.flows.update_beacon_malfunctions) extract_segments_of_year() (in module pipeline.src.shared_tasks.segments) extract_silenced_alerts() (in module pipeline.src.shared_tasks.alerts) extract_situ_atlant_areas() (in module pipeline.src.flows.admin_areas) extract_situ_med_areas() (in module pipeline.src.flows.admin_areas) extract_situ_memn_areas() (in module pipeline.src.flows.admin_areas) extract_situ_outre_mer_areas() (in module pipeline.src.flows.admin_areas) extract_situs_areas() (in module pipeline.src.flows.admin_areas) extract_species() (in module pipeline.src.flows.export_species) (in module pipeline.src.flows.species) extract_species_codes_groups() (in module pipeline.src.flows.init_species_groups) extract_species_groups() (in module pipeline.src.flows.init_species_groups) extract_species_names() (in module pipeline.src.flows.distribute_pnos) extract_suspicions_of_under_declaration() (in module pipeline.src.flows.suspicions_of_under_declaration_alerts) extract_threat_characterization() (in module pipeline.src.flows.init_infraction_threat_characterization) extract_threats() (in module pipeline.src.flows.init_infraction_threat_characterization) extract_total_trips() (in module pipeline.src.flows.risk_elements) extract_transversal_sea_limit_areas() (in module pipeline.src.flows.admin_areas) extract_trips_snapshot() (in module pipeline.src.flows.trips_snapshot) extract_trips_subject_to_pno() (in module pipeline.src.flows.risk_elements) extract_unece_locations() (in module pipeline.src.flows.ports) extract_unece_ports() (in module pipeline.src.flows.ports) extract_usual_segments() (in module pipeline.src.flows.risk_factors) extract_vessels_current_gears() (in module pipeline.src.flows.position_alert) extract_vessels_logbook_equipement() (in module pipeline.src.flows.vessels) extract_vessels_most_recent_control() (in module pipeline.src.flows.control_anteriority) extract_vessels_operators() (in module pipeline.src.flows.vessels) extract_vessels_that_emitted_fars() (in module pipeline.src.flows.missing_far_alerts) extract_vessels_that_should_emit() (in module pipeline.src.flows.update_beacon_malfunctions) extract_vessels_with_active_reportings() (in module pipeline.src.flows.enrich_logbook) extract_vessels_with_current_vms_fishing_activity() (in module pipeline.src.flows.risk_factors) extract_vessels_with_species_onboard() (in module pipeline.src.flows.position_alert) extract_vms_last_positions() (in module pipeline.src.flows.last_positions) extract_vms_static_positions() (in module pipeline.src.flows.anchorages) extract_vms_vessels() (in module pipeline.src.flows.risk_elements) extract_xmls_from_zipfile() (in module pipeline.src.flows.sales_and_logbook) extract_zipfiles() (in module pipeline.src.flows.sales_and_logbook)

F

facade (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) facade_areas_flow() (in module pipeline.src.flows.facade_areas) FAO_AREA (pipeline.src.entities.alerts.AdministrativeAreaType attribute) fao_area (pipeline.src.entities.pnos.PnoCatch attribute) fao_areas_flow() (in module pipeline.src.flows.fao_areas) FAX (pipeline.src.entities.communication_means.CommunicationMeans attribute) fetch_control_units() (in module pipeline.src.shared_tasks.control_units) filter_alerts() (in module pipeline.src.shared_tasks.alerts) filter_already_enriched_vessels() (in module pipeline.src.flows.enrich_positions) filter_column (pipeline.src.entities.alerts.AreasTableMetadata attribute) filter_control_units() (in module pipeline.src.flows.email_actions_to_units) filter_missions_control_units() (in module pipeline.src.flows.missions) filter_on_depth() (in module pipeline.src.flows.position_alert) filter_results() (in module pipeline.src.shared_tasks.control_flow) fishing_gear_codes_flow() (in module pipeline.src.flows.fishing_gear_codes) FISHING_OPERATION (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) FishingGear (class in pipeline.src.entities.fleet_segments) flag_active_ports() (in module pipeline.src.flows.ports) flag_pnos_to_verify_and_send() (in module pipeline.src.flows.enrich_logbook) flag_state (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) flag_states_iso2 (pipeline.src.entities.alerts.PositionAlertSpecification attribute) flatten() (in module pipeline.src.shared_tasks.control_flow) FleetSegment (class in pipeline.src.entities.fleet_segments) FlightGoal (class in pipeline.src.entities.missions) flow (pipeline.src.deployments.FlowAndSchedules attribute) flow_combine_circabc_unece_ports() (in module pipeline.src.flows.ports)

flow_geocode_ports() (in module pipeline.src.flows.ports) flow_make_circabc_ports() (in module pipeline.src.flows.ports) flow_make_unece_ports() (in module pipeline.src.flows.ports) flow_name (pipeline.src.entities.prefect.FlowRun attribute) flow_run_id (pipeline.src.entities.prefect.FlowRun attribute) FlowAndSchedules (class in pipeline.src.deployments) FlowRun (class in pipeline.src.entities.prefect) flows_to_deploy (in module pipeline.src.deployments) FLUX (pipeline.src.entities.data_exchange_standards.TransmissionFormat attribute) FluxFAReportDocumentType (class in pipeline.src.parsers.flux.flux) FluxFishingActivityType (class in pipeline.src.parsers.flux.flux) FLUXParsingError FMC (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationRecipientFunction attribute) FOLLOWING (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) FOREIGN_FMC (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationRecipientFunction attribute) foreign_fmc_emails (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) foreign_fmc_name (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) foreign_fmcs_flow() (in module pipeline.src.flows.foreign_fmcs) format_dead_links() (in module pipeline.src.flows.regulations_checkup) format_outdated_references() (in module pipeline.src.flows.regulations_checkup) FOUR_HOUR_REPORT (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) from_json() (pipeline.src.entities.monitorfish_healthcheck.MonitorfishHealthcheck static method) from_mission_action_type() (pipeline.src.entities.missions.MissionType static method) from_poseidon_control_type() (pipeline.src.entities.missions.MissionActionType static method) from_poseidon_infraction_field() (pipeline.src.entities.missions.InfractionType method) from_poseidon_status() (pipeline.src.entities.beacon_malfunctions.BeaconStatus static method) from_zipped_file_type() (pipeline.src.entities.data_exchange_standards.DataDomain static method) (pipeline.src.entities.data_exchange_standards.TransmissionFormat static method) function (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationAddressee attribute)

G

gear (pipeline.src.entities.alerts.GearSpecification attribute) GEAR_RETRIEVAL (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) GEAR_SHOT (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) gears (pipeline.src.entities.alerts.PositionAlertSpecification attribute) GearSpecification (class in pipeline.src.entities.alerts) generate_html() (in module pipeline.src.flows.activity_visualizations) generation_datetime_utc (pipeline.src.entities.pnos.RenderedPno attribute) geocode() (in module pipeline.src.helpers.spatial) geocode_google() (in module pipeline.src.helpers.spatial) geocode_ports() (in module pipeline.src.flows.ports) geocode_row() (in module pipeline.src.flows.ports) geocode_row_google() (in module pipeline.src.flows.ports) geometry_column (pipeline.src.entities.alerts.AreasTableMetadata attribute) get_actions_period() (in module pipeline.src.flows.email_actions_to_units) get_active_ports() (in module pipeline.src.flows.anchorages) get_addressees() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionMessageToSend method) (pipeline.src.entities.pnos.RenderedPno method) get_alerts_that_must_run_now() (in module pipeline.src.flows.position_alerts) get_anchorage_h3_cells() (in module pipeline.src.flows.anchorages) get_anchorage_h3_cells_rings() (in module pipeline.src.flows.anchorages) get_anchorages_closest_port() (in module pipeline.src.flows.anchorages) get_body_template() (in module pipeline.src.flows.regulations_checkup) get_control_unit_ids() (in module pipeline.src.flows.email_actions_to_units) get_csv_file_object() (in module pipeline.src.shared_tasks.datagouv) get_current_year() (in module pipeline.src.shared_tasks.dates) get_dates() (in module pipeline.src.flows.missing_far_alerts) get_datetime_intervals() (in module pipeline.src.helpers.dates) get_dead_links() (in module pipeline.src.flows.regulations_checkup) get_depth() (in module pipeline.src.helpers.bathymetry) get_element() (in module pipeline.src.parsers.flux.utils) get_email_addressees() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) get_email_body_template() (in module pipeline.src.flows.distribute_pnos) get_ended_malfunction_ids() (in module pipeline.src.flows.update_beacon_malfunctions) get_extraction_datetimes() (in module pipeline.src.flows.regulations_checkup) get_fa_report_type() (in module pipeline.src.parsers.flux.flux) get_fax_addressees() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) get_first_child() (in module pipeline.src.parsers.utils) get_first_non_null_column_name() (in module pipeline.src.processing) get_fishing_activity_type() (in module pipeline.src.parsers.flux.flux) get_formatted_malfunction_start_datetime_utc() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) get_geopackage_file_object() (in module pipeline.src.shared_tasks.datagouv) get_h3_indices() (in module pipeline.src.helpers.spatial)

get_html_for_pdf_template() (in module pipeline.src.flows.distribute_pnos) get_k_ring_of_h3_cells() (in module pipeline.src.helpers.spatial) get_last_emissions_of_vessels_that_should_emit() (in module pipeline.src.flows.update_beacon_malfunctions) get_list_fa_report_documents() (in module pipeline.src.parsers.flux.flux) get_log_type() (in module pipeline.src.parsers.flux.flux) get_main_template() (in module pipeline.src.flows.regulations_checkup) get_matched_groups() (in module pipeline.src.processing) get_missing_references() (in module pipeline.src.flows.regulations_checkup) get_modified_regulations() (in module pipeline.src.flows.regulations_checkup) get_monitorfish_healthcheck() (in module pipeline.src.shared_tasks.healthcheck) get_nearest_port() (pipeline.src.flows.anchorages.PortsVPTree method) get_new_malfunctions() (in module pipeline.src.flows.update_beacon_malfunctions) get_notification_subject() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) get_operation_type() (in module pipeline.src.parsers.flux.flux) get_outdated_references() (in module pipeline.src.flows.regulations_checkup) get_ports_locations() (in module pipeline.src.flows.anchorages) get_recipients() (in module pipeline.src.flows.regulations_checkup) get_regulations_for_csv() (in module pipeline.src.flows.regulations_open_data) get_regulations_for_geopackage() (in module pipeline.src.flows.regulations_open_data) get_root_tag() (in module pipeline.src.parsers.utils) get_sets_of_identifiers() (in module pipeline.src.flows.position_alert) get_sms_addressees() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) get_sms_template() (in module pipeline.src.flows.distribute_pnos) get_sms_templates() (in module pipeline.src.flows.notify_beacon_malfunctions) get_step_distances() (in module pipeline.src.helpers.spatial) get_style() (in module pipeline.src.flows.regulations_checkup) get_table() (in module pipeline.src.shared_tasks.infrastructure) (in module pipeline.src.utils) get_template() (in module pipeline.src.flows.email_actions_to_units) get_templates() (in module pipeline.src.flows.notify_beacon_malfunctions) get_text() (in module pipeline.src.parsers.flux.utils) get_time_range() (in module pipeline.src.flows.activity_visualizations) get_timezone_aware_utcnow() (in module pipeline.src.shared_tasks.dates) get_unknown_links() (in module pipeline.src.flows.regulations_checkup) get_unused_col_name() (in module pipeline.src.processing) get_utcnow() (in module pipeline.src.shared_tasks.dates) get_vessels_at_sea() (in module pipeline.src.flows.missing_far_alerts) get_vessels_in_alert() (in module pipeline.src.flows.position_alert) get_vessels_with_gears() (in module pipeline.src.flows.position_alert) get_vessels_with_missing_fars() (in module pipeline.src.flows.missing_far_alerts) get_vessels_with_species_min_weight() (in module pipeline.src.flows.position_alert) get_zipped_file_type() (in module pipeline.src.flows.sales_and_logbook) GRD (pipeline.src.entities.pnos.ReturnToPortPurpose attribute)

H

HEADERS (in module pipeline.src.shared_tasks.datagouv) HOUR (pipeline.src.shared_tasks.dates.TimeUnit attribute)

html_email_body (pipeline.src.entities.pnos.RenderedPno attribute) html_for_pdf (pipeline.src.entities.pnos.RenderedPno attribute)

I

id (pipeline.src.entities.alerts.PositionAlertSpecification attribute) (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) IN_FOREIGN_EEZ (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) IN_TEST (pipeline.src.entities.beacon_malfunctions.BeaconStatus attribute) Infraction (class in pipeline.src.entities.missions) infraction_rate_bins (in module pipeline.src.flows.control_anteriority) infractions_flow() (in module pipeline.src.flows.infractions) InfractionType (class in pipeline.src.entities.missions) init_2025_segments_flow() (in module pipeline.src.flows.init_2025_segments) init_infraction_threat_characterization_flow() (in module pipeline.src.flows.init_infraction_threat_characterization) init_pno_types_flow() (in module pipeline.src.flows.init_pno_types) init_species_groups_flow() (in module pipeline.src.flows.init_species_groups) INITIAL_ENCOUNTER (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) invalidate_cache() (in module pipeline.src.flows.ports) ircs (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute)

is_a_value() (in module pipeline.src.processing) is_activated (pipeline.src.entities.alerts.PositionAlertSpecification attribute) is_being_sent (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) is_correction (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) is_in_error (pipeline.src.entities.alerts.PositionAlertSpecification attribute) is_in_validity_period() (in module pipeline.src.helpers.dates) is_landing (pipeline.src.entities.pnos.PreRenderedPno attribute) is_prior_notification_zero() (in module pipeline.src.flows.distribute_pnos) is_verified (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) is_zero (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) isscaap_codes_flow() (in module pipeline.src.flows.isscaap_codes)

J

join() (in module pipeline.src.flows.last_positions) join_ais() (in module pipeline.src.flows.last_positions) join_on_multiple_keys() (in module pipeline.src.processing)

join_values_by_column() (in module pipeline.src.flows.isscaap_codes) JOINT_FISHING_OPERATION (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) json_converter() (in module pipeline.src.processing)

L

label (pipeline.src.entities.missions.FlightGoal property) label() (pipeline.src.entities.pnos.ReturnToPortPurpose method) LAN (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) LAND (pipeline.src.entities.missions.MissionType attribute) LAND_CONTROL (pipeline.src.entities.missions.MissionActionType attribute) land_controls (pipeline.src.entities.control_units.ControlUnitActions attribute) LANDING (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) last_control_datetime_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) last_control_infractions (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) last_position_latitude (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) last_position_longitude (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) last_positions_flow() (in module pipeline.src.flows.last_positions) latitude (pipeline.src.flows.anchorages.PortLocation attribute) (pipeline.src.helpers.spatial.Position attribute) (pipeline.src.helpers.spatial.PositionRepresentation attribute) lawType (pipeline.src.entities.alerts.RegulatoryAreaSpecification attribute) left_isin_right_by_decreasing_priority() (in module pipeline.src.processing) load() (in module pipeline.src.generic_tasks) load_1241_eaux_occidentales_australes_areas() (in module pipeline.src.flows.admin_areas) load_1241_eaux_occidentales_septentrionales_areas() (in module pipeline.src.flows.admin_areas) load_1241_eaux_union_dans_oi_et_atl_ouest_areas() (in module pipeline.src.flows.admin_areas) load_1241_mer_baltique_areas() (in module pipeline.src.flows.admin_areas) load_1241_mer_celtique_areas() (in module pipeline.src.flows.admin_areas) load_1241_mer_du_nord_areas() (in module pipeline.src.flows.admin_areas) load_1241_mer_mediterranee_areas() (in module pipeline.src.flows.admin_areas) load_1241_mer_noire_areas() (in module pipeline.src.flows.admin_areas) load_12_miles_areas() (in module pipeline.src.flows.admin_areas) load_2025_segments() (in module pipeline.src.flows.init_2025_segments) load_3_miles_areas() (in module pipeline.src.flows.admin_areas) load_6_miles_areas() (in module pipeline.src.flows.admin_areas) load_activity_visualization() (in module pipeline.src.flows.activity_visualizations) load_aem_areas() (in module pipeline.src.flows.admin_areas) load_alerts() (in module pipeline.src.shared_tasks.alerts) load_analytics_control_units_and_administrations() (in module pipeline.src.flows.control_units) load_anchorages_to_monitorfish() (in module pipeline.src.flows.anchorages) load_beacons() (in module pipeline.src.flows.beacons) load_brexit_areas() (in module pipeline.src.flows.admin_areas) load_cgpm_areas() (in module pipeline.src.flows.admin_areas) load_cgpm_statistical_rectangles_areas() (in module pipeline.src.flows.admin_areas) load_circabc() (in module pipeline.src.flows.ports) load_computed_trip_numbers() (in module pipeline.src.flows.missing_trip_numbers) load_control_anteriority() (in module pipeline.src.flows.control_anteriority) load_controls_segments() (in module pipeline.src.flows.recompute_controls_segments) load_cormoran_areas() (in module pipeline.src.flows.admin_areas) load_current_segments() (in module pipeline.src.flows.current_segments) load_departments_areas() (in module pipeline.src.flows.admin_areas) load_districts() (in module pipeline.src.flows.districts) load_eez_areas() (in module pipeline.src.flows.admin_areas) load_effort_zones_areas() (in module pipeline.src.flows.admin_areas) load_emails_sent_to_control_units() (in module pipeline.src.flows.email_actions_to_units) load_enriched_pnos() (in module pipeline.src.flows.enrich_logbook) load_facade_areas() (in module pipeline.src.flows.facade_areas) load_facades_zee_fr_shom() (in module pipeline.src.flows.admin_areas) load_fao_areas() (in module pipeline.src.flows.fao_areas) load_fao_ccamlr_areas() (in module pipeline.src.flows.admin_areas)

load_fao_iccat_areas() (in module pipeline.src.flows.admin_areas) load_fao_iotc_areas() (in module pipeline.src.flows.admin_areas) load_fao_siofa_areas() (in module pipeline.src.flows.admin_areas) load_fishing_activity() (in module pipeline.src.flows.enrich_positions) load_fishing_gear_codes() (in module pipeline.src.flows.fishing_gear_codes) load_fishing_gear_codes_groups() (in module pipeline.src.flows.fishing_gear_codes) load_foreign_fmcs() (in module pipeline.src.flows.foreign_fmcs) load_geocoded_ports() (in module pipeline.src.flows.ports) load_infractions() (in module pipeline.src.flows.infractions) load_land_areas() (in module pipeline.src.flows.admin_areas) load_last_positions() (in module pipeline.src.flows.last_positions) load_last_positions_ais() (in module pipeline.src.flows.last_positions) load_last_positions_vms() (in module pipeline.src.flows.last_positions) load_mission_actions() (in module pipeline.src.flows.controls) load_missions_and_missions_control_units() (in module pipeline.src.flows.controls) (in module pipeline.src.flows.missions) load_n_miles_to_shore_areas() (in module pipeline.src.flows.admin_areas) load_nafo_regulatory_area() (in module pipeline.src.flows.admin_areas) load_navigation_category_five_areas() (in module pipeline.src.flows.admin_areas) load_navigation_category_four_areas() (in module pipeline.src.flows.admin_areas) load_navigation_category_three_areas() (in module pipeline.src.flows.admin_areas) load_navigation_category_two_areas() (in module pipeline.src.flows.admin_areas) load_neafc_regulatory_area() (in module pipeline.src.flows.admin_areas) load_new_beacon_malfunctions() (in module pipeline.src.flows.update_beacon_malfunctions) load_new_regulations() (in module pipeline.src.flows.regulations) load_notifications() (in module pipeline.src.flows.notify_beacon_malfunctions) load_pno_pdf_documents() (in module pipeline.src.flows.distribute_pnos) load_pno_types_and_rules() (in module pipeline.src.flows.init_pno_types) load_port_codes() (in module pipeline.src.flows.ports) load_ports() (in module pipeline.src.flows.ports) load_prior_notification_sent_messages() (in module pipeline.src.flows.distribute_pnos) load_processed_anchorages() (in module pipeline.src.flows.anchorages) load_rectangles_stat_areas() (in module pipeline.src.flows.admin_areas) load_risk_factors() (in module pipeline.src.flows.risk_factors) load_sales_and_logbook_data() (in module pipeline.src.flows.sales_and_logbook) load_saltwater_limit_areas() (in module pipeline.src.flows.admin_areas) load_satellite_operators() (in module pipeline.src.flows.beacons) load_situ_atlant_areas() (in module pipeline.src.flows.admin_areas) load_situ_med_areas() (in module pipeline.src.flows.admin_areas) load_situ_memn_areas() (in module pipeline.src.flows.admin_areas) load_situ_outre_mer_areas() (in module pipeline.src.flows.admin_areas) load_situs_areas() (in module pipeline.src.flows.admin_areas) load_species() (in module pipeline.src.flows.species) load_species_groups() (in module pipeline.src.flows.init_species_groups) load_threat_characterization_and_join_table() (in module pipeline.src.flows.init_infraction_threat_characterization) load_transversal_sea_limit_areas() (in module pipeline.src.flows.admin_areas) load_trips_snapshot() (in module pipeline.src.flows.trips_snapshot) load_unece() (in module pipeline.src.flows.ports) load_vessel_profiles() (in module pipeline.src.flows.vessel_profiles) load_vessels() (in module pipeline.src.flows.vessels) load_vessels_risk_elements() (in module pipeline.src.flows.risk_elements) load_with_connection() (in module pipeline.src.generic_tasks) locode (pipeline.src.flows.anchorages.PortLocation attribute) LOGBOOK (pipeline.src.entities.data_exchange_standards.DataDomain attribute) (pipeline.src.entities.pnos.PnoSource attribute) longitude (pipeline.src.flows.anchorages.PortLocation attribute) (pipeline.src.helpers.spatial.Position attribute) (pipeline.src.helpers.spatial.PositionRepresentation attribute)

M

make_add_vessels_columns_query() (in module pipeline.src.helpers.vessels) make_alerts() (in module pipeline.src.shared_tasks.alerts) make_config() (in module pipeline.src.flows.activity_visualizations) make_connection_string() (in module pipeline.src.db_config) make_date() (in module pipeline.src.flows.ports) make_datetime() (in module pipeline.src.parsers.flux.utils) (in module pipeline.src.parsers.utils) make_find_vessels_query() (in module pipeline.src.helpers.vessels) make_html_hyperlinks() (in module pipeline.src.flows.regulations_checkup) make_infractions() (in module pipeline.src.helpers.controls) make_lat_lon() (in module pipeline.src.flows.ports) make_manual_prior_notifications_statement() (in module pipeline.src.flows.distribute_pnos) make_missions_actions_and_missions_control_units() (in module pipeline.src.flows.controls) make_periods() (in module pipeline.src.helpers.dates) (in module pipeline.src.shared_tasks.dates) make_positions_at_sea_query() (in module pipeline.src.flows.missing_far_alerts) make_positions_in_alert_query() (in module pipeline.src.flows.position_alert) make_prior_notification_attachments_query() (in module pipeline.src.flows.distribute_pnos) make_relativedelta() (in module pipeline.src.shared_tasks.dates) make_reset_requested_notifications_statement() (in module pipeline.src.flows.notify_beacon_malfunctions) make_timedelta() (in module pipeline.src.shared_tasks.dates) make_update_logbook_reports_statement() (in module pipeline.src.flows.distribute_pnos) make_vessels_query() (in module pipeline.src.flows.position_alert) MALFUNCTION_AT_PORT_INITIAL_NOTIFICATION (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_AT_PORT_INITIAL_NOTIFICATION_UNSUPERVISED_BEACON (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_AT_PORT_REMINDER (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_AT_SEA_INITIAL_NOTIFICATION (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_AT_SEA_INITIAL_NOTIFICATION_UNSUPERVISED_BEACON (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_AT_SEA_REMINDER (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) MALFUNCTION_NOTIFICATION_TO_FOREIGN_FMC (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType attribute) malfunction_start_date_utc (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) MANUAL (pipeline.src.entities.pnos.PnoSource attribute) maxMesh (pipeline.src.entities.alerts.GearSpecification attribute) merge() (in module pipeline.src.flows.control_anteriority) (in module pipeline.src.flows.risk_factors) merge_circabc_unece() (in module pipeline.src.flows.ports) merge_closest_port_closest_active_port() (in module pipeline.src.flows.anchorages) merge_controls_data() (in module pipeline.src.flows.controls) merge_dicts() (in module pipeline.src.processing) merge_hashes() (in module pipeline.src.flows.regulations) merge_pnos_data() (in module pipeline.src.flows.enrich_logbook) merge_risk_factor() (in module pipeline.src.flows.missing_far_alerts) (in module pipeline.src.flows.position_alert) merge_sets_of_identifiers() (in module pipeline.src.flows.position_alert) merge_vessel_id() (in module pipeline.src.helpers.vessels) merge_vessel_profiles() (in module pipeline.src.flows.vessel_profiles) mesh (pipeline.src.entities.fleet_segments.FishingGear attribute) message (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionMessageToSend attribute) (pipeline.src.entities.pnos.PnoToSend attribute) metadata (pipeline.src.entities.alerts.AdminAreasSpecWithTable attribute) min_depth (pipeline.src.entities.alerts.PositionAlertSpecification attribute) minMesh (pipeline.src.entities.alerts.GearSpecification attribute) MINUTE (pipeline.src.shared_tasks.dates.TimeUnit attribute) minWeight (pipeline.src.entities.alerts.SpeciesSpecification attribute) MISSING_DEP_ALERT (pipeline.src.entities.alerts.AlertType attribute) missing_dep_alerts_flow() (in module pipeline.src.flows.missing_dep_alerts) MISSING_FAR_48_HOURS_ALERT (pipeline.src.entities.alerts.AlertType attribute) MISSING_FAR_ALERT (pipeline.src.entities.alerts.AlertType attribute) missing_far_alerts_flow() (in module pipeline.src.flows.missing_far_alerts) missing_trip_numbers_flow() (in module pipeline.src.flows.missing_trip_numbers) MissionActionType (class in pipeline.src.entities.missions) MissionOrigin (class in pipeline.src.entities.missions) missions_flow() (in module pipeline.src.flows.missions) MissionType (class in pipeline.src.entities.missions) mmsi (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) model_post_init() (pipeline.src.entities.alerts.PositionAlertSpecification method) module pipeline.src pipeline.src.db_config pipeline.src.deployments pipeline.src.emails pipeline.src.entities pipeline.src.entities.alerts pipeline.src.entities.beacon_malfunctions pipeline.src.entities.communication_means pipeline.src.entities.control_units pipeline.src.entities.data_exchange_standards pipeline.src.entities.fleet_segments pipeline.src.entities.missions pipeline.src.entities.monitorfish_healthcheck pipeline.src.entities.pnos pipeline.src.entities.prefect pipeline.src.entities.risk_elements pipeline.src.entities.vessel_profiles pipeline.src.exceptions pipeline.src.exceptions.monitorfish_health_error pipeline.src.flows pipeline.src.flows.activity_visualizations pipeline.src.flows.admin_areas pipeline.src.flows.anchorages pipeline.src.flows.beacons pipeline.src.flows.control_anteriority pipeline.src.flows.control_units pipeline.src.flows.controls pipeline.src.flows.controls_open_data pipeline.src.flows.current_segments pipeline.src.flows.distribute_pnos pipeline.src.flows.districts pipeline.src.flows.email_actions_to_units pipeline.src.flows.enrich_logbook pipeline.src.flows.enrich_positions pipeline.src.flows.export_species pipeline.src.flows.facade_areas pipeline.src.flows.fao_areas pipeline.src.flows.fishing_gear_codes pipeline.src.flows.foreign_fmcs pipeline.src.flows.infractions pipeline.src.flows.init_2025_segments pipeline.src.flows.init_infraction_threat_characterization pipeline.src.flows.init_pno_types pipeline.src.flows.init_species_groups pipeline.src.flows.isscaap_codes pipeline.src.flows.last_positions pipeline.src.flows.missing_dep_alerts pipeline.src.flows.missing_far_alerts pipeline.src.flows.missing_trip_numbers pipeline.src.flows.missions pipeline.src.flows.notify_beacon_malfunctions pipeline.src.flows.ports pipeline.src.flows.position_alert pipeline.src.flows.position_alerts pipeline.src.flows.recompute_controls_segments pipeline.src.flows.refresh_materialized_view pipeline.src.flows.regulations pipeline.src.flows.regulations_checkup pipeline.src.flows.regulations_open_data pipeline.src.flows.risk_elements pipeline.src.flows.risk_factors pipeline.src.flows.sales_and_logbook pipeline.src.flows.species pipeline.src.flows.suspicions_of_under_declaration_alerts pipeline.src.flows.trips_snapshot pipeline.src.flows.update_beacon_malfunctions pipeline.src.flows.validate_pending_alerts pipeline.src.flows.vessel_profiles pipeline.src.flows.vessels pipeline.src.generic_tasks pipeline.src.helpers pipeline.src.helpers.alerts pipeline.src.helpers.bathymetry pipeline.src.helpers.controls pipeline.src.helpers.dates pipeline.src.helpers.emails pipeline.src.helpers.fao_areas pipeline.src.helpers.segments pipeline.src.helpers.spatial pipeline.src.helpers.vessels pipeline.src.parsers pipeline.src.parsers.ers pipeline.src.parsers.ers.childless_parsers pipeline.src.parsers.ers.ers pipeline.src.parsers.ers.log_parsers pipeline.src.parsers.ers.sal_parsers pipeline.src.parsers.flux pipeline.src.parsers.flux.childless_parsers pipeline.src.parsers.flux.flux pipeline.src.parsers.flux.log_parsers pipeline.src.parsers.flux.sales_parsers pipeline.src.parsers.flux.utils pipeline.src.parsers.utils pipeline.src.processing pipeline.src.read_query pipeline.src.scraping pipeline.src.shared_tasks pipeline.src.shared_tasks.alerts pipeline.src.shared_tasks.control_flow pipeline.src.shared_tasks.control_units pipeline.src.shared_tasks.datagouv pipeline.src.shared_tasks.dates pipeline.src.shared_tasks.facades pipeline.src.shared_tasks.healthcheck pipeline.src.shared_tasks.infrastructure pipeline.src.shared_tasks.pnos pipeline.src.shared_tasks.positions pipeline.src.shared_tasks.risk_factors pipeline.src.shared_tasks.segments pipeline.src.shared_tasks.vessels pipeline.src.utils

MONITORENV (pipeline.src.entities.missions.MissionOrigin attribute) MONITORFISH (pipeline.src.entities.missions.MissionOrigin attribute) MonitorfishHealthcheck (class in pipeline.src.entities.monitorfish_healthcheck) MonitorfishHealthError, [1] MONTH (pipeline.src.shared_tasks.dates.TimeUnit attribute) MOT_MR (pipeline.src.entities.risk_elements.RiskElement attribute) move() (in module pipeline.src.utils)

N

name (pipeline.src.entities.alerts.PositionAlertSpecification attribute) (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationAddressee attribute) (pipeline.src.entities.fleet_segments.FishingGear attribute) (pipeline.src.entities.fleet_segments.FleetSegment attribute) (pipeline.src.entities.pnos.PnoAddressee attribute) natinf (pipeline.src.entities.missions.Infraction attribute) natinf_code (pipeline.src.entities.alerts.PositionAlertSpecification attribute) NEAFC_AREA (pipeline.src.entities.alerts.AdministrativeAreaType attribute) NO_NEWS (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) NON_APPROVED (pipeline.src.entities.beacon_malfunctions.BeaconStatus attribute)

note (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) NOTIFICATION (pipeline.src.parsers.flux.flux.FluxFAReportDocumentType attribute) notification_type (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) notify_beacon_malfunctions_flow() (in module pipeline.src.flows.notify_beacon_malfunctions) NS_FLUX (in module pipeline.src.parsers.flux.utils) NS_FLUX_SALES (in module pipeline.src.parsers.flux.sales_parsers) null_parser() (in module pipeline.src.parsers.flux.log_parsers) number_of_actions (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) number_of_fish (pipeline.src.entities.pnos.PnoCatch attribute)

O

ON_SALE (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) only_fishing_positions (pipeline.src.entities.alerts.PositionAlertSpecification attribute) operation_datetime_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) operator_email (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute)

operator_fax (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) operator_mobile_phone (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) operator_name (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) organization (pipeline.src.entities.pnos.PnoAddressee attribute) OTH (pipeline.src.entities.pnos.ReturnToPortPurpose attribute)

P

parse() (in module pipeline.src.parsers.ers.ers) parse_() (in module pipeline.src.parsers.ers.ers) parse_coe() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_cor() (in module pipeline.src.parsers.ers.ers) parse_cox() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_cro() (in module pipeline.src.parsers.ers.log_parsers) parse_css() (in module pipeline.src.parsers.ers.childless_parsers) parse_cst() (in module pipeline.src.parsers.ers.childless_parsers) parse_del() (in module pipeline.src.parsers.ers.ers) parse_dep() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_dis() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_ecps() (in module pipeline.src.parsers.ers.log_parsers) parse_edci() (in module pipeline.src.parsers.ers.childless_parsers) parse_eof() (in module pipeline.src.parsers.ers.log_parsers) parse_ers() (in module pipeline.src.parsers.ers.ers) parse_fa_report_document() (in module pipeline.src.parsers.flux.flux) parse_fa_report_message_string() (in module pipeline.src.parsers.flux.flux) parse_far() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_gea() (in module pipeline.src.parsers.ers.childless_parsers) (in module pipeline.src.parsers.flux.childless_parsers) parse_lan() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_log() (in module pipeline.src.parsers.ers.ers) parse_metadata() (in module pipeline.src.parsers.flux.flux) parse_ops() (in module pipeline.src.parsers.ers.ers) parse_pdf() (in module pipeline.src.flows.isscaap_codes) parse_pno() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_ports_names() (in module pipeline.src.flows.ports) parse_pos() (in module pipeline.src.parsers.ers.childless_parsers) parse_pro() (in module pipeline.src.parsers.ers.childless_parsers) (in module pipeline.src.parsers.flux.childless_parsers) parse_product() (in module pipeline.src.parsers.flux.sales_parsers) parse_ras() (in module pipeline.src.parsers.ers.childless_parsers) (in module pipeline.src.parsers.flux.childless_parsers) parse_ret() (in module pipeline.src.parsers.ers.ers) parse_rtp() (in module pipeline.src.parsers.ers.log_parsers) (in module pipeline.src.parsers.flux.log_parsers) parse_sal() (in module pipeline.src.parsers.ers.ers) parse_sales_document() (in module pipeline.src.parsers.flux.sales_parsers) parse_sales_ops() (in module pipeline.src.parsers.ers.ers) parse_sales_report_message_string() (in module pipeline.src.parsers.flux.sales_parsers) parse_sli() (in module pipeline.src.parsers.ers.sal_parsers) parse_spe() (in module pipeline.src.parsers.ers.childless_parsers) (in module pipeline.src.parsers.flux.childless_parsers) parse_specified_fishing_activity() (in module pipeline.src.parsers.flux.flux) parse_src() (in module pipeline.src.parsers.ers.childless_parsers) parse_tli() (in module pipeline.src.parsers.ers.sal_parsers) parse_xml_string() (in module pipeline.src.parsers.ers.ers) parse_xmls() (in module pipeline.src.flows.sales_and_logbook) parsers (in module pipeline.src.parsers.ers.ers) pdf_document (pipeline.src.entities.pnos.RenderedPno attribute) Period (class in pipeline.src.helpers.dates) period (pipeline.src.entities.control_units.ControlUnitActions attribute) phone_numbers (pipeline.src.entities.control_units.ControlUnit attribute) pipeline.src module pipeline.src.db_config module pipeline.src.deployments module pipeline.src.emails module pipeline.src.entities module pipeline.src.entities.alerts module pipeline.src.entities.beacon_malfunctions module pipeline.src.entities.communication_means module pipeline.src.entities.control_units module pipeline.src.entities.data_exchange_standards module pipeline.src.entities.fleet_segments module pipeline.src.entities.missions module pipeline.src.entities.monitorfish_healthcheck module pipeline.src.entities.pnos module pipeline.src.entities.prefect module pipeline.src.entities.risk_elements module pipeline.src.entities.vessel_profiles module pipeline.src.exceptions module pipeline.src.exceptions.monitorfish_health_error module pipeline.src.flows module pipeline.src.flows.activity_visualizations module pipeline.src.flows.admin_areas module pipeline.src.flows.anchorages module pipeline.src.flows.beacons module pipeline.src.flows.control_anteriority module pipeline.src.flows.control_units module pipeline.src.flows.controls module pipeline.src.flows.controls_open_data module pipeline.src.flows.current_segments module pipeline.src.flows.distribute_pnos module pipeline.src.flows.districts module pipeline.src.flows.email_actions_to_units module pipeline.src.flows.enrich_logbook module pipeline.src.flows.enrich_positions module pipeline.src.flows.export_species module pipeline.src.flows.facade_areas module pipeline.src.flows.fao_areas module pipeline.src.flows.fishing_gear_codes module pipeline.src.flows.foreign_fmcs module pipeline.src.flows.infractions module pipeline.src.flows.init_2025_segments module pipeline.src.flows.init_infraction_threat_characterization module pipeline.src.flows.init_pno_types module pipeline.src.flows.init_species_groups module pipeline.src.flows.isscaap_codes module pipeline.src.flows.last_positions module pipeline.src.flows.missing_dep_alerts module pipeline.src.flows.missing_far_alerts module pipeline.src.flows.missing_trip_numbers module pipeline.src.flows.missions module pipeline.src.flows.notify_beacon_malfunctions module pipeline.src.flows.ports module pipeline.src.flows.position_alert module

pipeline.src.flows.position_alerts module pipeline.src.flows.recompute_controls_segments module pipeline.src.flows.refresh_materialized_view module pipeline.src.flows.regulations module pipeline.src.flows.regulations_checkup module pipeline.src.flows.regulations_open_data module pipeline.src.flows.risk_elements module pipeline.src.flows.risk_factors module pipeline.src.flows.sales_and_logbook module pipeline.src.flows.species module pipeline.src.flows.suspicions_of_under_declaration_alerts module pipeline.src.flows.trips_snapshot module pipeline.src.flows.update_beacon_malfunctions module pipeline.src.flows.validate_pending_alerts module pipeline.src.flows.vessel_profiles module pipeline.src.flows.vessels module pipeline.src.generic_tasks module pipeline.src.helpers module pipeline.src.helpers.alerts module pipeline.src.helpers.bathymetry module pipeline.src.helpers.controls module pipeline.src.helpers.dates module pipeline.src.helpers.emails module pipeline.src.helpers.fao_areas module pipeline.src.helpers.segments module pipeline.src.helpers.spatial module pipeline.src.helpers.vessels module pipeline.src.parsers module pipeline.src.parsers.ers module pipeline.src.parsers.ers.childless_parsers module pipeline.src.parsers.ers.ers module pipeline.src.parsers.ers.log_parsers module pipeline.src.parsers.ers.sal_parsers module pipeline.src.parsers.flux module pipeline.src.parsers.flux.childless_parsers module pipeline.src.parsers.flux.flux module pipeline.src.parsers.flux.log_parsers module pipeline.src.parsers.flux.sales_parsers module pipeline.src.parsers.flux.utils module pipeline.src.parsers.utils module pipeline.src.processing module pipeline.src.read_query module pipeline.src.scraping module pipeline.src.shared_tasks module pipeline.src.shared_tasks.alerts module pipeline.src.shared_tasks.control_flow module pipeline.src.shared_tasks.control_units module pipeline.src.shared_tasks.datagouv module pipeline.src.shared_tasks.dates module pipeline.src.shared_tasks.facades module pipeline.src.shared_tasks.healthcheck module pipeline.src.shared_tasks.infrastructure module pipeline.src.shared_tasks.pnos module pipeline.src.shared_tasks.positions module pipeline.src.shared_tasks.risk_factors module pipeline.src.shared_tasks.segments module pipeline.src.shared_tasks.vessels module pipeline.src.utils module pno (pipeline.src.entities.pnos.PnoToSend attribute) PNO_MR (pipeline.src.entities.risk_elements.RiskElement attribute) pno_types (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) PnoAddressee (class in pipeline.src.entities.pnos) PnoCatch (class in pipeline.src.entities.pnos) PnoSource (class in pipeline.src.entities.pnos) PnoToRender (class in pipeline.src.entities.pnos) PnoToSend (class in pipeline.src.entities.pnos) point_dist() (in module pipeline.src.helpers.spatial) port_locode (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) port_name (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.flows.anchorages.PortLocation attribute) PortLocation (class in pipeline.src.flows.anchorages) ports_flow() (in module pipeline.src.flows.ports) PortsVPTree (class in pipeline.src.flows.anchorages) POSEIDON_CACEM (pipeline.src.entities.missions.MissionOrigin attribute) POSEIDON_CNSP (pipeline.src.entities.missions.MissionOrigin attribute) Position (class in pipeline.src.helpers.spatial) POSITION_ALERT (pipeline.src.entities.alerts.AlertType attribute) position_alert_flow() (in module pipeline.src.flows.position_alert) position_alert_specification_must_run_now() (in module pipeline.src.helpers.alerts) position_alerts_flow() (in module pipeline.src.flows.position_alerts) position_to_position_representation() (in module pipeline.src.helpers.spatial) PositionAlertSpecification (class in pipeline.src.entities.alerts) PositionRepresentation (class in pipeline.src.helpers.spatial) pre_render_pno() (in module pipeline.src.flows.distribute_pnos) predicted_arrival_datetime_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) predicted_landing_datetime_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) prepare_df_for_loading() (in module pipeline.src.processing) prepare_new_beacon_malfunctions() (in module pipeline.src.flows.update_beacon_malfunctions) PreRenderedPno (class in pipeline.src.entities.pnos) previous_notification_date_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) previous_notification_datetime_utc (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) prior_notification_report_id (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) prior_notification_source (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) PriorNotificationSentMessage (class in pipeline.src.entities.pnos) producer_organizations (pipeline.src.entities.alerts.PositionAlertSpecification attribute) psql_insert_copy() (in module pipeline.src.utils) purpose (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) purpose_suffix (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute)

R

read_query() (in module pipeline.src.read_query) read_query_task() (in module pipeline.src.generic_tasks) read_saved_query() (in module pipeline.src.read_query) read_table() (in module pipeline.src.read_query) RECEIVED_DIRECTORY (in module pipeline.src.flows.sales_and_logbook) RECENT (pipeline.src.entities.vessel_profiles.VesselProfileType attribute) recipient_address_or_number (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) recipient_function (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) recipient_name (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) recipient_organization (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) recompute_controls_segments_flow() (in module pipeline.src.flows.recompute_controls_segments) REF (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) refresh_materialized_view_flow() (in module pipeline.src.flows.refresh_materialized_view) refresh_view() (in module pipeline.src.flows.refresh_materialized_view) regulations_checkup_flow() (in module pipeline.src.flows.regulations_checkup) regulations_flow() (in module pipeline.src.flows.regulations) regulations_open_data_flow() (in module pipeline.src.flows.regulations_open_data) regulatory_areas (pipeline.src.entities.alerts.PositionAlertSpecification attribute) RegulatoryAreaSpecification (class in pipeline.src.entities.alerts) RELOCATION (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) remove_file() (in module pipeline.src.utils) remove_namespace() (in module pipeline.src.parsers.utils) remove_none_values() (in module pipeline.src.parsers.flux.utils) remove_nones_from_dict() (in module pipeline.src.processing) remove_nones_from_list() (in module pipeline.src.processing) remove_redundant_fao_area_codes() (in module pipeline.src.helpers.fao_areas)

render() (in module pipeline.src.flows.email_actions_to_units) (in module pipeline.src.flows.notify_beacon_malfunctions) render_body() (in module pipeline.src.flows.regulations_checkup) render_main() (in module pipeline.src.flows.regulations_checkup) render_pno() (in module pipeline.src.flows.distribute_pnos) render_sms() (in module pipeline.src.flows.notify_beacon_malfunctions) RenderedPno (class in pipeline.src.entities.pnos) REP (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) repeat_each_year (pipeline.src.entities.alerts.PositionAlertSpecification attribute) replace_pandas_nat() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify method) report_datetime_utc (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) report_id (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) request_notification() (in module pipeline.src.flows.update_beacon_malfunctions) RES (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) reset_computed_trip_numbers() (in module pipeline.src.flows.missing_trip_numbers) reset_pnos() (in module pipeline.src.flows.enrich_logbook) resize_pdf_to_A4() (in module pipeline.src.helpers.emails) RESUMED_TRANSMISSION (pipeline.src.entities.beacon_malfunctions.EndOfMalfunctionReason attribute) ReturnToPortPurpose (class in pipeline.src.entities.pnos) risk_elements_flow() (in module pipeline.src.flows.risk_elements) risk_factor (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) risk_factors_flow() (in module pipeline.src.flows.risk_factors) risk_factors_prefix (pipeline.src.entities.vessel_profiles.VesselProfileType property) RiskElement (class in pipeline.src.entities.risk_elements) rows_belong_to_sequence() (in module pipeline.src.processing)

S

SALES (pipeline.src.entities.data_exchange_standards.DataDomain attribute) sales_and_logbook_flow() (in module pipeline.src.flows.sales_and_logbook) SATELLITE_OPERATOR (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationRecipientFunction attribute) satellite_operator (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) satellite_operator_emails (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) schedules (pipeline.src.deployments.FlowAndSchedules attribute) SCR (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) SEA (pipeline.src.entities.missions.MissionType attribute) SEA_CONTROL (pipeline.src.entities.missions.MissionActionType attribute) sea_controls (pipeline.src.entities.control_units.ControlUnitActions attribute) SECOND (pipeline.src.shared_tasks.dates.TimeUnit attribute) select_ids_to_delete() (in module pipeline.src.flows.regulations) select_ids_to_update() (in module pipeline.src.flows.regulations) send_beacon_malfunction_message() (in module pipeline.src.flows.notify_beacon_malfunctions) send_email() (in module pipeline.src.helpers.emails) send_email_or_sms_or_fax_message() (in module pipeline.src.helpers.emails) send_fax() (in module pipeline.src.helpers.emails) send_message() (in module pipeline.src.flows.regulations_checkup) send_mission_actions_email() (in module pipeline.src.flows.email_actions_to_units) send_pno_message() (in module pipeline.src.flows.distribute_pnos) send_sms() (in module pipeline.src.helpers.emails) sending_datetime_utc (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) serialize_datetime() (in module pipeline.src.parsers.utils) serialize_nullable_integer_df() (in module pipeline.src.processing) serialize_timedelta_df() (in module pipeline.src.processing) SHE (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) simple_parser() (in module pipeline.src.parsers.ers.ers)

SMS (pipeline.src.entities.communication_means.CommunicationMeans attribute) sms_content (pipeline.src.entities.pnos.RenderedPno attribute) source (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) species (pipeline.src.entities.alerts.PositionAlertSpecification attribute) (pipeline.src.entities.alerts.SpeciesSpecification attribute) species_catch_areas (pipeline.src.entities.alerts.PositionAlertSpecification attribute) species_code (pipeline.src.entities.pnos.PnoCatch attribute) species_flow() (in module pipeline.src.flows.species) species_name (pipeline.src.entities.pnos.PnoCatch attribute) species_name_code (pipeline.src.entities.pnos.PnoCatch attribute) SpeciesSpecification (class in pipeline.src.entities.alerts) specified_fishing_activity_parsers (in module pipeline.src.parsers.flux.flux) split() (in module pipeline.src.flows.last_positions) start (pipeline.src.helpers.dates.Period attribute) START_ACTIVITY (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) START_FISHING (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) state (pipeline.src.entities.prefect.FlowRun attribute) state_timestamp (pipeline.src.entities.prefect.FlowRun attribute) statistical_rectangle (pipeline.src.entities.pnos.PnoCatch attribute) str_to_path() (in module pipeline.src.shared_tasks.control_flow) success (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotification attribute) (pipeline.src.entities.control_units.ControlUnitActionsSentMessage attribute) (pipeline.src.entities.pnos.PriorNotificationSentMessage attribute) SUSPENDED_BECAUSE_UNPAID (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) SUSPICION_OF_UNDER_DECLARATION_ALERT (pipeline.src.entities.alerts.AlertType attribute) suspicions_of_under_declaration_alerts_flow() (in module pipeline.src.flows.suspicions_of_under_declaration_alerts)

T

table (pipeline.src.entities.alerts.AdminAreasSpecWithTable attribute) table_name (pipeline.src.entities.alerts.AreasTableMetadata attribute) tag_positions_at_port() (in module pipeline.src.shared_tasks.positions) tagged_children() (in module pipeline.src.parsers.utils) TARGETING_VESSEL (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionStage attribute) TECHNICAL_STOP (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionVesselStatus attribute) test_mode (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) threat (pipeline.src.entities.alerts.PositionAlertSpecification attribute) threat_characterization (pipeline.src.entities.alerts.PositionAlertSpecification attribute) TimeUnit (class in pipeline.src.shared_tasks.dates) to_admin_areas_spec_with_table() (in module pipeline.src.flows.position_alert) to_admin_areas_table_metadata() (in module pipeline.src.flows.position_alert) to_control_unit_actions() (in module pipeline.src.flows.email_actions_to_units) to_json() (in module pipeline.src.processing) to_malfunctions_to_notify_list() (in module pipeline.src.flows.notify_beacon_malfunctions) to_multipolygon() (in module pipeline.src.helpers.spatial) to_notification_subject_template() (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationType method) to_pgarr() (in module pipeline.src.processing) to_pnos_to_render() (in module pipeline.src.flows.distribute_pnos) to_position_alert_specifications() (in module pipeline.src.flows.position_alerts) to_regulatory_area_filter() (in module pipeline.src.flows.position_alert) topic (pipeline.src.entities.alerts.RegulatoryAreaSpecification attribute) TRA (pipeline.src.entities.pnos.ReturnToPortPurpose attribute) track_analysis_depth (pipeline.src.entities.alerts.PositionAlertSpecification attribute) transform_beacons() (in module pipeline.src.flows.beacons) transform_catch_controls() (in module pipeline.src.flows.controls)

transform_controls() (in module pipeline.src.flows.controls) transform_controls_open_data() (in module pipeline.src.flows.controls_open_data) transform_fao_areas() (in module pipeline.src.flows.fao_areas) transform_fleet_segments_open_data() (in module pipeline.src.flows.controls_open_data) transform_foreign_fmcs_contacts() (in module pipeline.src.flows.foreign_fmcs) transform_gear_onboard() (in module pipeline.src.flows.vessel_profiles) transform_isscaap_codes() (in module pipeline.src.flows.isscaap_codes) transform_modified_regulations() (in module pipeline.src.flows.regulations_checkup) transform_ports_open_data() (in module pipeline.src.flows.ports) transform_profiles() (in module pipeline.src.flows.vessel_profiles) transform_satellite_operators() (in module pipeline.src.flows.beacons) transform_species() (in module pipeline.src.flows.export_species) (in module pipeline.src.flows.species) transform_vessels_most_recent_control() (in module pipeline.src.flows.control_anteriority) TRANSHIPMENT (pipeline.src.parsers.flux.flux.FluxFishingActivityType attribute) TransmissionFormat (class in pipeline.src.entities.data_exchange_standards) TREATED_DIRECTORY (in module pipeline.src.flows.sales_and_logbook) trip_gears (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) trip_segments (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) trips_snapshot_flow() (in module pipeline.src.flows.trips_snapshot) try_float() (in module pipeline.src.parsers.utils) try_get_factory() (in module pipeline.src.processing) try_int() (in module pipeline.src.parsers.utils)

U

UN_JBE (pipeline.src.entities.data_exchange_standards.ZippedFileType attribute) UN_NVE (pipeline.src.entities.data_exchange_standards.ZippedFileType attribute) UNAUTHORIZED_FISHING (pipeline.src.entities.missions.FlightGoal attribute) unite_ports_locodes() (in module pipeline.src.flows.anchorages) UNSUPERVISED (pipeline.src.entities.beacon_malfunctions.BeaconStatus attribute)

update_beacon_malfunction() (in module pipeline.src.flows.update_beacon_malfunctions) update_beacon_malfunctions_flow() (in module pipeline.src.flows.update_beacon_malfunctions) update_required() (in module pipeline.src.flows.regulations) update_resource() (in module pipeline.src.shared_tasks.datagouv) USUAL (pipeline.src.entities.vessel_profiles.VesselProfileType attribute)

V

validate_action() (in module pipeline.src.flows.last_positions) validate_pending_alert() (in module pipeline.src.shared_tasks.alerts) validate_pending_alerts_flow() (in module pipeline.src.flows.validate_pending_alerts) validity_end_datetime_utc (pipeline.src.entities.alerts.PositionAlertSpecification attribute) validity_start_datetime_utc (pipeline.src.entities.alerts.PositionAlertSpecification attribute) VESSEL_CAPTAIN (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationRecipientFunction attribute) vessel_cfr_or_immat_or_ircs (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) vessel_emails (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) vessel_fax (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) vessel_id (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) vessel_ids (pipeline.src.entities.alerts.PositionAlertSpecification attribute)

vessel_length (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) vessel_mobile_phone (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) vessel_name (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionToNotify attribute) (pipeline.src.entities.pnos.PnoToRender attribute) (pipeline.src.entities.pnos.PreRenderedPno attribute) (pipeline.src.entities.pnos.RenderedPno attribute) VESSEL_OPERATOR (pipeline.src.entities.beacon_malfunctions.BeaconMalfunctionNotificationRecipientFunction attribute) vessel_profiles_flow() (in module pipeline.src.flows.vessel_profiles) vessel_profiles_prefix (pipeline.src.entities.vessel_profiles.VesselProfileType property) VesselProfileType (class in pipeline.src.entities.vessel_profiles) vessels_flow() (in module pipeline.src.flows.vessels) VMS_AIS_CHECK (pipeline.src.entities.missions.FlightGoal attribute) VMS_MR (pipeline.src.entities.risk_elements.RiskElement attribute)

W

weight (pipeline.src.entities.pnos.PnoCatch attribute)

WITH_RECORD (pipeline.src.entities.missions.InfractionType attribute) WITHOUT_RECORD (pipeline.src.entities.missions.InfractionType attribute)

Y

YEAR (pipeline.src.shared_tasks.dates.TimeUnit attribute)

Z

zeros_ones_to_bools() (in module pipeline.src.processing)

ZippedFileType (class in pipeline.src.entities.data_exchange_standards) zone (pipeline.src.entities.alerts.RegulatoryAreaSpecification attribute)