airflow/utils/dag_processing.py
def max_runs_reached(self):
        """
        :return: whether all file paths have been processed max_runs times
        """
        if self._max_runs == -1:  # Unlimited runs.
            return False
        for file_path in self._file_paths:
            if self._run_count[file_path] < self._max_runs:
                return False
        if self._run_count[self._heart_beat_key] < self._max_runs:
            return False
        return True
def max_runs_reached(self):
        """
        :return: whether all file paths have been processed max_runs times
        """
        if self._max_runs == -1:  # Unlimited runs.
            return False
        for file_path in self._file_paths:
            if self._run_count[file_path] < self._max_runs:
                return False
        if self._run_count[self._heart_beat_key] < self._max_runs:
            return False
        return True
def max_runs_reached ( self ) : if self . _max_runs == - 1 : # Unlimited runs. return False for file_path in self . _file_paths : if self . _run_count [ file_path ] < self . _max_runs : return False if self . _run_count [ self . _heart_beat_key ] < self . _max_runs : return False return True
:return: whether all file paths have been processed max_runs times
: return : whether all file paths have been processed max_runs times