Skip to content
Snippets Groups Projects
Commit 12825627 authored by Andrew Kapuscinski's avatar Andrew Kapuscinski
Browse files

Add logger for ingest complete

parent 4926ddd7
No related branches found
Tags end-of-sprint-14
1 merge request!307Add logger for ingest complete
Pipeline #2006 passed
...@@ -28,8 +28,8 @@ services: ...@@ -28,8 +28,8 @@ services:
parallelism: 0 parallelism: 0
order: stop-first order: stop-first
volumes: volumes:
- /lustre/aoc/cluster/pipeline/dsoc-dev/downloads/nrao:/lustre/aoc/cluster/pipeline/dsoc-dev/downloads/nrao - /lustre/aoc/cluster/pipeline/dsoc-${ENV}/downloads/nrao:/lustre/aoc/cluster/pipeline/dsoc-${ENV}/downloads/nrao
- /lustre/aoc/cluster/pipeline/dsoc-dev/workspaces:/lustre/aoc/cluster/pipeline/dsoc-dev/workspaces - /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/ssa/bin/python3.8:/home/ssa/bin/python3.8
- /home/casa/capo:/home/casa/capo - /home/casa/capo:/home/casa/capo
......
...@@ -31,6 +31,10 @@ class ArchiveService(ArchiveServiceIF): ...@@ -31,6 +31,10 @@ class ArchiveService(ArchiveServiceIF):
""" """
logdata = message["logData"] logdata = message["logData"]
# log message for Demo
logger.info(f"ingestion-complete event: {logdata}")
execblock_id = logdata["execblock_id"] execblock_id = logdata["execblock_id"]
fileset_id = logdata["fileset_id"] fileset_id = logdata["fileset_id"]
project_code = logdata["project_code"] project_code = logdata["project_code"]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment