add filter_warnings

import json

import os.path

import subprocess

import warnings

from astropy import time

            n_jobs_cpu=18,

            n_jobs_gpu=9,

            device="CPU",

            filter_warnings=False,

    ):

        self.dir_in = dir_in

        self.dir_out = dir_out

        self.dfs = DFS(n_try=5)

        self.crds = CRDS()

        if filter_warnings:

            self.filter_warnings()

    def set_test_env(self):

        os.environ["CSST_DFS_API_MODE"] = "cluster"

        os.environ["CSST_DFS_GATEWAY"] = "172.24.27.2:30880"

    def now(self):

        return time.Time.now().isot

    @staticmethod

    def filter_warnings():

        # Suppress all warnings

        warnings.filterwarnings("ignore")

    @staticmethod

    def reset_warnings(self):

        # Reset warning filters

        warnings.resetwarnings()

class Message:

    def __init__(self, file_path=""):