From 12825627f75f5b98b4bdd87fbdfd14301c6c0ba3 Mon Sep 17 00:00:00 2001
From: Andrew Kapuscinski <akapusci@nrao.edu>
Date: Fri, 25 Jun 2021 16:24:24 +0000
Subject: [PATCH] Add logger for ingest complete
---
docker-compose.dev.yml | 4 ++--
.../workspaces/products/services/archive_service.py | 4 ++++
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/docker-compose.dev.yml b/docker-compose.dev.yml
index 4efebd4ff..0b8b37590 100644
--- a/docker-compose.dev.yml
+++ b/docker-compose.dev.yml
@@ -28,8 +28,8 @@ services:
parallelism: 0
order: stop-first
volumes:
- - /lustre/aoc/cluster/pipeline/dsoc-dev/downloads/nrao:/lustre/aoc/cluster/pipeline/dsoc-dev/downloads/nrao
- - /lustre/aoc/cluster/pipeline/dsoc-dev/workspaces:/lustre/aoc/cluster/pipeline/dsoc-dev/workspaces
+ - /lustre/aoc/cluster/pipeline/dsoc-${ENV}/downloads/nrao:/lustre/aoc/cluster/pipeline/dsoc-${ENV}/downloads/nrao
+ - /lustre/aoc/cluster/pipeline/dsoc-${ENV}/workspaces:/lustre/aoc/cluster/pipeline/dsoc-${ENV}/workspaces
- /home/ssa/bin/python3.8:/home/ssa/bin/python3.8
- /home/casa/capo:/home/casa/capo
diff --git a/shared/workspaces/workspaces/products/services/archive_service.py b/shared/workspaces/workspaces/products/services/archive_service.py
index 89459c590..ad383bca3 100644
--- a/shared/workspaces/workspaces/products/services/archive_service.py
+++ b/shared/workspaces/workspaces/products/services/archive_service.py
@@ -31,6 +31,10 @@ class ArchiveService(ArchiveServiceIF):
"""
logdata = message["logData"]
+
+ # log message for Demo
+ logger.info(f"ingestion-complete event: {logdata}")
+
execblock_id = logdata["execblock_id"]
fileset_id = logdata["fileset_id"]
project_code = logdata["project_code"]
--
GitLab