LaunchAgent

  less than a minute  

View the source code

run が与えられた run キューをポーリングし、wandb の Launch 用に run を起動する Launch agent クラス。

LaunchAgent(
    api: Api,
    config: Dict[str, Any]
)
引数
api バックエンドへのリクエストを行うために使用する Api オブジェクト。
config agent の設定辞書。
属性
num_running_jobs スケジューラを含まないジョブの数を返します。
num_running_schedulers スケジューラの数だけを返します。
thread_ids agent のスレッド ID を実行しているキーのリストを返します。

メソッド

check_sweep_state

ソースを表示

check_sweep_state(
    launch_spec, api
)

sweep の 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
)

今のところ、ジョブをリストから削除します。

get_job_and_queue

ソースを表示

get_job_and_queue()

initialized

ソースを表示

@classmethod
initialized() -> bool

agent が初期化されているかどうかを返します。

loop

ソースを表示

loop()

ジョブを無限にポーリングして実行します。

例外
KeyboardInterrupt agent が停止を要求された場合。

name

ソースを表示

@classmethod
name() -> str

agent の名前を返します。

pop_from_queue

ソースを表示

pop_from_queue(
    queue
)

ジョブとして実行するために、runqueue からアイテムをポップします。

引数
queue ポップするキュー。
戻り値
キューからポップされたアイテム。
例外
Exception キューからのポップ中にエラーが発生した場合。

ソースを表示

print_status() -> None

agent の現在のステータスを出力します。

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
)

agent のステータスを更新します。

引数
status agent を更新するステータス。

最終更新 April 3, 2025