pipeline.src.flows.risk_elements

Functions

extract_total_trips(→ pandas.DataFrame)
extract_vms_vessels(→ pandas.DataFrame)
extract_trips_subject_to_pno(→ pandas.DataFrame)
extract_rtps(→ pandas.DataFrame)
extract_logbook_pnos(→ pandas.DataFrame)
extract_manual_pnos(→ pandas.DataFrame)
evaluate_trips_pnos(→ pandas.DataFrame)
compute_pno_mr_trips_per_vessel(...)
extract_occurrences(→ pandas.DataFrame)
extract_compliant_trips(→ pandas.DataFrame)
compute_occurrences_vessels_risk_elements(vessels, ...)
compute_vessels_risk_elements(total_trips, ...)
load_vessels_risk_elements(vessels_risk_elements)
risk_elements_flow()

Module Contents

pipeline.src.flows.risk_elements.extract_total_trips(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_vms_vessels(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_trips_subject_to_pno(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_rtps(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_logbook_pnos(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_manual_pnos(from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.evaluate_trips_pnos(trips_subject_to_pno: pandas.DataFrame, rtps: pandas.DataFrame, manual_pnos: pandas.DataFrame, logbook_pnos: pandas.DataFrame) → pandas.DataFrame

pipeline.src.flows.risk_elements.compute_pno_mr_trips_per_vessel(evaluated_trips_pnos: pandas.DataFrame) → Tuple[pandas.DataFrame, pandas.DataFrame]

pipeline.src.flows.risk_elements.extract_occurrences(risk_element: src.entities.risk_elements.RiskElement, from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.extract_compliant_trips(risk_element: src.entities.risk_elements.RiskElement, from_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.risk_elements.compute_occurrences_vessels_risk_elements(vessels: pandas.DataFrame, occurrences: pandas.DataFrame, risk_element: src.entities.risk_elements.RiskElement)

pipeline.src.flows.risk_elements.compute_vessels_risk_elements(total_trips: pandas.DataFrame, compliant_trips: pandas.DataFrame, risk_element: src.entities.risk_elements.RiskElement)

pipeline.src.flows.risk_elements.load_vessels_risk_elements(vessels_risk_elements: pandas.DataFrame)

pipeline.src.flows.risk_elements.risk_elements_flow()