From 5349acc767ef0efa4b5dada6c0ecfb562ab5794d Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Wed, 9 Aug 2023 14:16:12 -0500 Subject: [PATCH] update logs. fix upload --- .../event_handlers/archivers/TapisSystemArchiver.py | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/src/engine/src/contrib/tapis/middleware/event_handlers/archivers/TapisSystemArchiver.py b/src/engine/src/contrib/tapis/middleware/event_handlers/archivers/TapisSystemArchiver.py index 7515a9d6..9caeed20 100644 --- a/src/engine/src/contrib/tapis/middleware/event_handlers/archivers/TapisSystemArchiver.py +++ b/src/engine/src/contrib/tapis/middleware/event_handlers/archivers/TapisSystemArchiver.py @@ -92,14 +92,8 @@ def archive(self, archive, pipeline, params, logger): path=os.path.join(archive_output_dir, filename), file=blob, _x_tapis_tenant=params.tapis_tenant_id, - _x_tapis_user=archive.owner, - # _x_tapis_token=service_client.service_tokens["admin"]["access_token"].access_token - # headers={ - # "X-Tapis-Tenant": params.tapis_tenant_id, - # "X-Tapis-User": archive.owner, - # "X-Tapis-Token": service_client.service_tokens["admin"]["access_token"].access_token - # } + _x_tapis_user=archive.owner ) - logger.info(f"[PIPELINE] {pipeline.id} [ARCHIVED] {path_to_file}") + logger.info(f"[PIPELINE] {pipeline.id} [ARCHIVED] {filename}") except Exception as e: - logger.error(f"FAILED TO ARCHIVE TASK '{task.id}' OUTPUT '{filename}': {e}") + logger.error(f"FAILED TO ARCHIVE OUTPUT '{filename}' FOR TASK '{task.id}': {e}")