run.py

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=True,
    ccds=True,
)
p.info()


# parse JSON message
p.pipeline_logger.info(f"sys.argv = {sys.argv}")
exit(0)