메인 콘텐츠로 건너뛰기

View the source code

run 큐를 폴링하고 wandb Launch에 대한 run을 시작하는 Launch 에이전트 클래스입니다.
LaunchAgent(
    api: Api,
    config: Dict[str, Any]
)
인수Description
api백엔드에 요청을 보내는 데 사용할 Api 오브젝트입니다.
config에이전트의 구성 사전입니다.
속성Description
num_running_jobs스케줄러를 포함하지 않는 작업 수를 반환합니다.
num_running_schedulers스케줄러 수만 반환합니다.
thread_ids에이전트에 대해 실행 중인 스레드 ID의 키 목록을 반환합니다.

메소드

check_sweep_state

소스 보기
check_sweep_state(
    launch_spec, api
)
스윕에 대한 run을 시작하기 전에 스윕의 상태를 확인합니다.

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
)
현재 작업 목록에서 작업을 제거합니다.

get_job_and_queue

소스 보기
get_job_and_queue()

initialized

소스 보기
@classmethod
initialized() -> bool
에이전트가 초기화되었는지 여부를 반환합니다.

loop

소스 보기
loop()
작업을 폴링하고 실행하기 위해 무한 루프합니다.
예외Description
KeyboardInterrupt에이전트가 중지 요청을 받은 경우 발생합니다.

name

소스 보기
@classmethod
name() -> str
에이전트의 이름을 반환합니다.

pop_from_queue

소스 보기
pop_from_queue(
    queue
)
runqueue에서 항목을 팝하여 작업으로 실행합니다.
인수Description
queue팝할 큐입니다.
반환 값
큐에서 팝된 항목입니다.
예외Description
Exception큐에서 팝하는 동안 오류가 발생한 경우 발생합니다.
소스 보기
print_status() -> None
에이전트의 현재 상태를 출력합니다.

run_job

소스 보기
run_job(
    job, queue, file_saver
)
프로젝트를 설정하고 작업을 실행합니다.
인수Description
job실행할 작업입니다.

task_run_job

소스 보기
task_run_job(
    launch_spec, job, default_config, api, job_tracker
)

update_status

소스 보기
update_status(
    status
)
에이전트의 상태를 업데이트합니다.
인수Description
status에이전트를 업데이트할 상태입니다.
I