update Pipeline

    2023-12-15, Bo Zhang, add module header

"""

import json

import subprocess

import os

import shutil

import subprocess

import traceback

import warnings

from typing import Callable, NamedTuple, Optional, Any

        filter_warnings: bool = False,

        dfs: bool = True,

        ccds: bool = False,

        clean_output_before_run: bool = True,

        **kwargs: Any,

    ):

        # get pipeline information from env vars

        self.ccds_root = ccds_root

        self.ccds_cache = ccds_cache

        if clean_output_before_run:

            self.clean_output()

        # additional parameters

        self.kwargs = kwargs