def METHOD_NAME(self, raise_warnings=False):
    """
    Check the status of all steps
    """
    if (
        self.source.get_status().failures
        and self._get_source_success() < SUCCESS_THRESHOLD_VALUE
    ):
        raise WorkflowExecutionError(
            "Source reported errors", self.source.get_status()
        )
    for step in self.steps:
        if step.status.failures:
            raise WorkflowExecutionError(
                f"{step.__class__.__name__} reported errors", step.get_status()
            )
        if raise_warnings and step.status.warnings:
            raise WorkflowExecutionError(
                f"{step.__class__.__name__} reported warnings", step.get_status()
            )