diff --git a/datascience/src/pipeline/flows/historic_controls.py b/datascience/src/pipeline/flows/historic_controls.py index 618dd4169d..8c9801c2b4 100644 --- a/datascience/src/pipeline/flows/historic_controls.py +++ b/datascience/src/pipeline/flows/historic_controls.py @@ -195,8 +195,6 @@ def make_env_actions(historic_controls: pd.DataFrame) -> pd.DataFrame: axis=1, ) - breakpoint() - # fin du preprocessing historic_controls.drop( ["action_number_of_controls", "Themes", "natinf", "infractions"], diff --git a/datascience/src/pipeline/queries/fmc/historic_missions.sql b/datascience/src/pipeline/queries/fmc/historic_missions.sql index 6e99d29eb1..03b85964d5 100644 --- a/datascience/src/pipeline/queries/fmc/historic_missions.sql +++ b/datascience/src/pipeline/queries/fmc/historic_missions.sql @@ -11,7 +11,6 @@ FMC2.FMC_CODE_PLAN_FACADE.LIBELLE as facade, FMC2.FMC_BC_MISSION.DATE_DEBUT_MISSION as start_datetime_utc, FMC2.FMC_BC_MISSION.DATE_FIN_MISSION as end_datetime_utc, FMC2.FMC_BC_MISSION.TRIGRAMME_UTILISATEUR_CLOTURE AS closed_by, -'{ENV}' AS mission_nature, 'POSEIDON_CACEM' AS mission_source, FMC2.FMC_BC_MISSION.CLOTURER as closed diff --git a/datascience/tests/test_pipeline/test_flows/test_historic_controls.py b/datascience/tests/test_pipeline/test_flows/test_historic_controls.py index a21f3e1a9e..3843aafb37 100644 --- a/datascience/tests/test_pipeline/test_flows/test_historic_controls.py +++ b/datascience/tests/test_pipeline/test_flows/test_historic_controls.py @@ -99,15 +99,6 @@ pd.Timestamp("22/04/2017 10:30:00"), ], "closed_by": ["VSQ", "VSQ", "GYT", "RIO", "CBG", "VSQ", "VSQ"], - "mission_nature": [ - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - ], "mission_source": [ "POSEIDON_CACEM", "POSEIDON_CACEM", @@ -377,15 +368,6 @@ def transformed_historic_missions() -> pd.DataFrame: pd.Timestamp("22/04/2017 10:30:00"), ], "closed_by": ["VSQ", "VSQ", "GYT", "RIO", "CBG", "VSQ", "VSQ"], - "mission_nature": [ - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - "{ENV}", - ], "mission_source": [ "POSEIDON_CACEM", "POSEIDON_CACEM", @@ -476,7 +458,6 @@ def mock_extract_historic_missions_units_in_flow() -> pd.DataFrame: def test_make_env_actions(historic_controls, transformed_historic_controls): with patch("src.pipeline.flows.historic_controls.uuid", mock_uuid): res = make_env_actions.run(historic_controls) - breakpoint() pd.testing.assert_frame_equal(res, transformed_historic_controls) @@ -513,7 +494,7 @@ def test_flow( query_missions = ( "SELECT id, mission_types, open_by, observations_cacem, facade," - " start_datetime_utc, closed_by, mission_nature, mission_source," + " start_datetime_utc, closed_by, mission_source," " closed, observations_cnsp, deleted, geom FROM missions ORDER BY id" ) initial_missions = read_query("monitorenv_remote", query_missions)