@staticmethod
    def clean_db():
        clear_db_runs()
        clear_db_pools()
        clear_db_dags()
        clear_db_sla_miss()
        clear_db_import_errors()
        clear_db_jobs()
        clear_db_serialized_dags()
    def setup_class(self):
        self.clean_db()
    def setup_method(self):
        
        
        self.null_exec = MockExecutor()
        self.scheduler_job = None
    def teardown_method(self) -> None:
        if self.scheduler_job and self.scheduler_job.processor_agent:
            self.scheduler_job.processor_agent.end()
            self.scheduler_job = None
        self.clean_db()
    def _process_file(self, file_path, dag_directory, session):