LaunchAgent - CoreWeave Docs

소스 코드 보기

지정된 run 큐를 폴링하고 wandb launch를 위해 run을 실행하는 Launch 에이전트 클래스입니다.

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

인수	설명
`api`	백엔드에 요청을 보내는 데 사용할 API 객체입니다.
`config`	에이전트의 설정 딕셔너리입니다.

속성	설명
`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()

무한 반복하며 작업을 폴링하고 실행합니다.

예외	설명
`KeyboardInterrupt`	에이전트에 중지가 요청된 경우.

`name`

소스 보기

@classmethod
name() -> str

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

`pop_from_queue`

소스 보기

pop_from_queue(
    queue
)

run 큐에서 항목을 꺼내 작업으로 실행합니다.

인수	설명
`queue`	항목을 꺼낼 큐입니다.

반환값	설명
큐에서 꺼낸 항목입니다.

예외	설명
`Exception`	큐에서 항목을 꺼내는 중 오류가 발생한 경우입니다.

`print_status`

소스 보기

print_status() -> None

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

`run_job`

소스 보기

run_job(
    job, queue, file_saver
)

프로젝트를 설정하고 작업을 실행하세요.

인수	설명
`job`	실행할 작업.

`task_run_job`

소스 보기

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

`update_status`

소스 보기

update_status(
    status
)

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

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

소스 코드 보기

​메서드

​check_sweep_state

​fail_run_queue_item

​finish_thread_id

​get_job_and_queue

​initialized

​loop

​name

​pop_from_queue

​print_status

​run_job

​task_run_job

​update_status

메서드

`check_sweep_state`

`fail_run_queue_item`

`finish_thread_id`

`get_job_and_queue`

`initialized`

`loop`

`name`

`pop_from_queue`

`print_status`

`run_job`

`task_run_job`

`update_status`