diff --git a/process/process_series.py b/process/process_series.py index 56f8044..e553631 100755 --- a/process/process_series.py +++ b/process/process_series.py @@ -262,7 +262,7 @@ def decode_task_json(json_string: Optional[str]) -> Any: # Print the log out of the module logger.info("=== MODULE OUTPUT - BEGIN ========================================") if container.logs() is not None: - logs = container.logs().decode("utf-8") + logs = container.logs(timestamps=True).decode("utf-8") if not config.mercure.processing_logs.discard_logs: monitor.send_process_logs(task.id, task_processing.module_name, logs) logger.info(logs)