From 6803850acc24943936aabbd5f6f74220a3df405b Mon Sep 17 00:00:00 2001 From: davidmunoznovoa Date: Tue, 3 Dec 2024 17:14:37 +0100 Subject: [PATCH 1/3] Do not patch CUPSDAT indicador_envio_medida --- mesures/cupsdat.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/mesures/cupsdat.py b/mesures/cupsdat.py index b2a5ebb..39fea33 100644 --- a/mesures/cupsdat.py +++ b/mesures/cupsdat.py @@ -74,12 +74,12 @@ def reader(self, file_path): if row['fecha_hora_final_vigencia'] == '' else datetime.strptime(row['fecha_hora_final_vigencia'], '%Y-%m-%d %H').strftime(DATE_MASK), axis=1) - # Patch indicador_tipo_medida if needed - if 'indicador_envio_medida' in self.columns: - df['indicador_envio_medida'] = df.apply( - lambda row: 'Q' - if row['tipo'] in ('1', '2') or not row.get('indicador_envio_medida', False) - else row['indicador_envio_medida'], axis=1) + # # Patch indicador_tipo_medida if needed + # if 'indicador_envio_medida' in self.columns: + # df['indicador_envio_medida'] = df.apply( + # lambda row: 'Q' + # if row['tipo'] in ('1', '2') or not row.get('indicador_envio_medida', False) + # else row['indicador_envio_medida'], axis=1) return df[self.columns] From 220fcb4f377a9446ee95ed359173cc7051fe5e5e Mon Sep 17 00:00:00 2001 From: davidmunoznovoa Date: Tue, 3 Dec 2024 17:17:52 +0100 Subject: [PATCH 2/3] Patch as hourly --- mesures/cupsdat.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/mesures/cupsdat.py b/mesures/cupsdat.py index 39fea33..d0d5cd0 100644 --- a/mesures/cupsdat.py +++ b/mesures/cupsdat.py @@ -74,12 +74,12 @@ def reader(self, file_path): if row['fecha_hora_final_vigencia'] == '' else datetime.strptime(row['fecha_hora_final_vigencia'], '%Y-%m-%d %H').strftime(DATE_MASK), axis=1) - # # Patch indicador_tipo_medida if needed - # if 'indicador_envio_medida' in self.columns: - # df['indicador_envio_medida'] = df.apply( - # lambda row: 'Q' - # if row['tipo'] in ('1', '2') or not row.get('indicador_envio_medida', False) - # else row['indicador_envio_medida'], axis=1) + # Patch indicador_tipo_medida if needed + if 'indicador_envio_medida' in self.columns: + df['indicador_envio_medida'] = df.apply( + lambda row: 'H' + if not row.get('indicador_envio_medida', False) + else row['indicador_envio_medida'], axis=1) return df[self.columns] From 037e13f067bba3c0988c8bdd74feb4d2e474e583 Mon Sep 17 00:00:00 2001 From: davidmunoznovoa Date: Tue, 3 Dec 2024 17:25:40 +0100 Subject: [PATCH 3/3] Do not patch field. Addapt tests --- mesures/cupsdat.py | 7 ------- spec/generation_files_spec.py | 1 + 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/mesures/cupsdat.py b/mesures/cupsdat.py index d0d5cd0..56ad64e 100644 --- a/mesures/cupsdat.py +++ b/mesures/cupsdat.py @@ -74,13 +74,6 @@ def reader(self, file_path): if row['fecha_hora_final_vigencia'] == '' else datetime.strptime(row['fecha_hora_final_vigencia'], '%Y-%m-%d %H').strftime(DATE_MASK), axis=1) - # Patch indicador_tipo_medida if needed - if 'indicador_envio_medida' in self.columns: - df['indicador_envio_medida'] = df.apply( - lambda row: 'H' - if not row.get('indicador_envio_medida', False) - else row['indicador_envio_medida'], axis=1) - return df[self.columns] def writer(self): diff --git a/spec/generation_files_spec.py b/spec/generation_files_spec.py index f66d2c4..117e5f7 100644 --- a/spec/generation_files_spec.py +++ b/spec/generation_files_spec.py @@ -712,6 +712,7 @@ def get_sample_cupsdat_data(): def get_sample_cupsdat_data_isp_2024(): res = SampleData().get_sample_cupsdat_data() res[0].update({'indicador_envio_medida': 'Q'}) + res[1].update({'indicador_envio_medida': 'Q'}) return res @staticmethod