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`

View source

check_sweep_state(
    launch_spec, api
)

sweep の run を起動する前に、sweep の状態を確認します。

`fail_run_queue_item`

View source

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

`finish_thread_id`

View source

finish_thread_id(
    thread_id, exception=None
)

ジョブをリストから一時的に削除します。

`get_job_and_queue`

View source

get_job_and_queue()

`initialized`

View source

@classmethod
initialized() -> bool

エージェントが初期化されているかどうかを返します。

`loop`

View source

loop()

無限ループでジョブをポーリングし、実行します。

送出される例外	説明
`KeyboardInterrupt`	エージェントの停止が要求された場合。

`name`

View source

@classmethod
name() -> str

エージェント名を返します。

`pop_from_queue`

View source

pop_from_queue(
    queue
)

run キューから項目を取り出し、ジョブとして実行します。

引数	説明
`queue`	項目を取り出すキューです。

戻り値	説明
キューから取り出された項目です。

送出される例外	説明
`Exception`	キューからの取り出し時にエラーが発生した場合。

`print_status`

View source

print_status() -> None

エージェントの現在のステータスを出力します。

`run_job`

View source

run_job(
    job, queue, file_saver
)

project を設定し、ジョブを実行します。

引数	説明
`job`	実行するジョブ。

`task_run_job`

View source

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

`update_status`

View source

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`