def METHOD_NAME() -> List[IndicatorPeriodAggregationJob]:
    """
    Find jobs that are supposed to be running but with a dead process and fail them
    """
    dead_jobs = []
    for running_job in get_running_jobs():
        if not is_job_dead(running_job):
            continue
        running_job.mark_failed()
        dead_jobs.append(running_job)
        if running_job.attempts <= 1:
            email_job_owners(
                running_job,
                "indicator_aggregation/fail_subject.txt",
                "indicator_aggregation/fail_message.html",
                reason="Process died",
            )
        logger.warning(
            "Aggregation job died. ID %s. Indicator '%s'",
            running_job.id,
            running_job.period.indicator.title,
        )
    return dead_jobs