From 78e0da15b3d4994f41e0e9823e0c50b395dbf096 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=A9bastien=20BEAU?= Date: Fri, 22 Apr 2022 15:39:57 +0200 Subject: [PATCH] chunk_processing: add filename on chunk item --- chunk_processing/components/splitter_json.py | 3 +++ chunk_processing/models/chunk_item.py | 7 +++++++ chunk_processing/views/chunk_item_view.xml | 3 ++- 3 files changed, 12 insertions(+), 1 deletion(-) diff --git a/chunk_processing/components/splitter_json.py b/chunk_processing/components/splitter_json.py index 0220e6c1..40f16d31 100644 --- a/chunk_processing/components/splitter_json.py +++ b/chunk_processing/components/splitter_json.py @@ -12,6 +12,9 @@ class ChunkSplitterJson(Component): _name = "chunk.splitter.json" _usage = "json" + def _convert_items_to_data(self, items): + return json.dumps(items, indent=2).encode("utf-8") + def _parse_data(self, data): items = json.loads(data.decode("utf-8")) for idx, item in enumerate(items): diff --git a/chunk_processing/models/chunk_item.py b/chunk_processing/models/chunk_item.py index 92113825..1fcd4e94 100644 --- a/chunk_processing/models/chunk_item.py +++ b/chunk_processing/models/chunk_item.py @@ -32,6 +32,13 @@ class ChunkItem(models.Model): ("failed", "Failed"), ] ) + filename = fields.Char(compute="_compute_filename") + + def _compute_filename(self): + for record in self: + record.filename = ( + f"{record.start_idx}-{record.stop_idx}.{record.group_id.data_format}" + ) def manual_run(self): """ Run the import without try/except, easier for debug """ diff --git a/chunk_processing/views/chunk_item_view.xml b/chunk_processing/views/chunk_item_view.xml index f1d30232..3b69ab4a 100644 --- a/chunk_processing/views/chunk_item_view.xml +++ b/chunk_processing/views/chunk_item_view.xml @@ -23,7 +23,8 @@ - + +