LaunchAgent

소스 코드 보기

주어진 run queue를 폴링(poll)하고 wandb Launch 를 위해 run 을 실행하는 Launch 에이전트 클래스입니다.

LaunchAgent(
    api: Api,
    config: Dict[str, Any]
)

인수	설명
api	백엔드에 요청을 보내는 데 사용할 Api 오브젝트입니다.
config	에이전트를 위한 설정 사전(Config dictionary)입니다.

속성	설명
num_running_jobs	스케줄러를 제외하고 실행 중인 job의 수를 반환합니다.
num_running_schedulers	실행 중인 스케줄러의 수만 반환합니다.
thread_ids	에이전트에서 실행 중인 스레드 ID의 키 리스트를 반환합니다.

​

메소드

​

check_sweep_state

소스 보기

check_sweep_state(
    launch_spec, api
)

Sweeps 에 대한 run 을 실행하기 전에 Sweep 의 상태를 확인합니다.

​

fail_run_queue_item

소스 보기

fail_run_queue_item(
    run_queue_item_id, message, phase, files=None
)

​

finish_thread_id

소스 보기

finish_thread_id(
    thread_id, exception=None
)

현재 리스트에서 job을 제거합니다.

​

get_job_and_queue

소스 보기

get_job_and_queue()

​

initialized

소스 보기

@classmethod
initialized() -> bool

에이전트가 초기화되었는지 여부를 반환합니다.

​

loop

소스 보기

loop()

무한 루프를 돌며 job을 폴링하고 실행합니다.

Raises	설명
KeyboardInterrupt	에이전트 중단 요청이 있을 경우 발생합니다.

​

name

소스 보기

@classmethod
name() -> str

에이전트의 이름을 반환합니다.

​

pop_from_queue

소스 보기

pop_from_queue(
    queue
)

runqueue에서 아이템을 꺼내 job으로 실행합니다.

인수	설명
queue	아이템을 꺼낼 큐입니다.

반환값	설명
큐에서 꺼낸 아이템입니다.

Raises	설명
Exception	큐에서 아이템을 꺼내는 도중 오류가 발생할 경우 발생합니다.

​

print_status

소스 보기

print_status() -> None

에이전트의 현재 상태를 출력합니다.

​

run_job

소스 보기

run_job(
    job, queue, file_saver
)

Projects 를 설정하고 job을 실행합니다.

인수	설명
job	실행할 job입니다.

​

task_run_job

소스 보기

task_run_job(
    launch_spec, job, default_config, api, job_tracker
)

​

update_status

소스 보기

update_status(
    status
)

에이전트의 상태를 업데이트합니다.

인수	설명
status	에이전트에 업데이트할 상태입니다.