dag_filelocs.extend(
                                [
                                    os.path.join(fileloc, info.filename)
                                    for info in z.infolist()
                                    if might_contain_dag(info.filename, True, z)
                                ]
                            )
                    except zipfile.BadZipFile as err:
                        self.log.error("There was an err accessing %s, %s", fileloc, err)
                else:
                    dag_filelocs.append(fileloc)
            SerializedDagModel.remove_deleted_dags(
                alive_dag_filelocs=dag_filelocs,
                processor_subdir=self.get_dag_directory(),
            )
            DagModel.deactivate_deleted_dags(self._file_paths)
            from airflow.models.dagcode import DagCode
            DagCode.remove_deleted_code(dag_filelocs)
            return True
        return False
    def _print_stat(self):
        """Occasionally print out stats about how fast the files are getting processed."""
        if 0 < self.print_stats_interval < time.monotonic() - self.last_stat_print_time:
            if self._file_paths:
                self._log_file_processing_stats(self._file_paths)
            self.last_stat_print_time = time.monotonic()
    @staticmethod
    @internal_api_call
    @provide_session
    def clear_nonexistent_import_errors(file_paths: list[str] | None, session=NEW_SESSION):