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

tweaks

parent e06ff877
Pipeline #2256 failed with stage
in 0 seconds
......@@ -43,18 +43,12 @@ class Pipeline:
# set logger
self.pipeline_logger = get_logger(
name="pipeline",
filename=os.path.join(
self.dir_output,
"pipeline.log",
),
name="pipeline logger",
filename=os.path.join(self.dir_output, "pipeline.log"),
)
self.module_logger = get_logger(
name="module",
filename=os.path.join(
self.dir_output,
"module.log",
),
name="module logger",
filename=os.path.join(self.dir_output, "module.log"),
)
# change working directory
......@@ -62,12 +56,8 @@ class Pipeline:
os.chdir(self.dir_output)
# Frequently used files
self.msg = MessageWriter(
os.path.join(self.dir_output, "message.txt"),
)
self.tsr = TimeStampRecorder(
os.path.join(self.dir_output, "time_stamp.txt"),
)
self.msg = MessageWriter(os.path.join(self.dir_output, "message.txt"))
self.tsr = TimeStampRecorder(os.path.join(self.dir_output, "timestamp.txt"))
# self.exit_code = ExitCode(os.path.join(self.dir_output, "exit_code"))
# self.error_trace = ErrorTrace(os.path.join(self.dir_output, "error_trace"))
......@@ -76,7 +66,10 @@ class Pipeline:
else:
self.dfs = None
if ccds:
self.ccds = CCDS()
self.ccds = CCDS(
ccds_root=ccds_root,
ccds_cache=ccds_cache,
)
else:
self.ccds = None
......
from .data_manager import CsstMsDataManager
from .logger import get_logger
from .status import CsstStatus
from .file_recorder import FileRecorder
__all__ = ["CsstMsDataManager", "get_logger", "FileRecorder"]
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