Commit ae1ad549 authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

tweaks

parent 5b965d42
import os
import sys
from csst_common.cicd import Pipeline
# configure pipeline
p = Pipeline(
dir_input="/pipeline/input",
dir_output="/pipeline/output",
dir_aux="/pipeline/aux",
dfs_root="/dfs_root",
ccds_root="/ccds_root",
ccds_cache="/pipeline/ccds_cache",
pipeline_log="pipeline.log",
clean_output_before_run=True,
filter_warnings=False,
dfs=False,
ccds=False,
)
p = Pipeline()
p.info()
p.logger.info("Hello, world!")
p.logger.info(f"p.task = {p.task}")
# parse JSON message
if len(sys.argv) == 2:
msg = sys.argv[1]
else:
raise ValueError("sys.argv[1] is required")
d = p.message.msg2dict(msg)
print(f"Input message: {d}")
p.pipeline_logger.info(f"sys.argv = {sys.argv}")
exit(0)
\ No newline at end of file
exit(p.EXIT_CODES["success"])
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment