https://github.com/apache/airflow/blob/main/airflow/dag_processing/manager.py#L773
num_errors,
                    f"{last_runtime:.2f}s" if last_runtime else None,
                    last_run.strftime("%Y-%m-%dT%H:%M:%S") if last_run else None,
                )
            )
        log_str = (
            "\n"
            + "=" * 80
            + "\n"
            + "DAG File Processing Stats\n\n"
            + tabulate(formatted_rows, headers=headers)
            + "\n"
            + "=" * 80
        )
        self.log.info(log_str)
    def get_pid(self, file_path) -> int | None:
        """
        Retrieve the PID of the process processing the given file or None if the file is not being processed.
        :param file_path: the path to the file that's being processed
        """
        if file_path in self._processors:
            return self._processors[file_path].pid
        return None
    def get_all_pids(self) -> list[int]:
        """
        Get all pids.
        :return: a list of the PIDs for the processors that are running
        """
        return [x.pid for x in self._processors.values()]
    def get_last_runtime(self, file_path) -> float | None: