def METHOD_NAME():
    """The scheduler sends jobs to this coroutine. If the 'exclude' key
    is found in the hints, it is run in exclusive mode. We keep an internal
    record of these jobs, and whether they are 'waiting', 'running' or 'done'.
    """
    while True:
        key, job = yield
        if job.hints and 'exclude' in job.hints:
            j = Job(task=job.hints['id'],
                    exclude=job.hints['exclude'],
                    state='waiting',
                    job=job,
                    key=key)
            jobs[j.task] = j
            key_task[key] = j.task
            try_to_start(j.task)
        else:
            job_sink.send((key, job))