LaunchAgent - CoreWeave Docs

Voir le code source

Classe d’agent Launch qui interroge les files d’attente de run indiquées et lance des runs pour wandb launch.

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

Arguments	Description
`api`	Objet Api à utiliser pour envoyer des requêtes au backend.
`config`	Dictionnaire de configuration de l’agent.

Attributs	Description
`num_running_jobs`	Renvoie le nombre de jobs, hors schedulers.
`num_running_schedulers`	Renvoie uniquement le nombre de schedulers.
`thread_ids`	Renvoie une liste de clés correspondant aux ID des threads en cours d’exécution de l’agent.

Méthodes

`check_sweep_state`

Voir la source

check_sweep_state(
    launch_spec, api
)

Vérifie l’état d’un sweep avant de lancer un run de ce sweep.

`fail_run_queue_item`

Voir la source

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

`finish_thread_id`

Voir la source

finish_thread_id(
    thread_id, exception=None
)

Retire temporairement le job de notre liste.

`get_job_and_queue`

Voir la source

get_job_and_queue()

`initialized`

Voir la source

@classmethod
initialized() -> bool

Renvoie une valeur indiquant si l’agent est initialisé.

`loop`

Voir la source

loop()

Boucle indéfiniment pour interroger les files d’attente à la recherche de jobs, puis les exécuter.

Exceptions levées	Description
`KeyboardInterrupt`	si l’arrêt de l’agent est demandé.

`name`

Voir la source

@classmethod
name() -> str

Renvoie le nom de l’agent.

`pop_from_queue`

Voir la source

pop_from_queue(
    queue
)

Retire un élément de la file d’attente de runs pour l’exécuter en tant que job.

Arguments	Description
`queue`	File d’attente dont retirer l’élément.

Renvoie	Description
Élément retiré de la file d’attente.

Exceptions levées	Description
`Exception`	si une erreur survient lors du retrait d’un élément de la file d’attente.

`print_status`

Voir la source

print_status() -> None

Affiche le statut actuel de l’agent.

`run_job`

Voir la source

run_job(
    job, queue, file_saver
)

Configure le projet et exécute le job.

Arguments	Description
`job`	Job à exécuter.

`task_run_job`

Voir la source

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

`update_status`

Voir la source

update_status(
    status
)

Met à jour le statut de l’agent.

Arguments	Description
`status`	Nouveau statut à attribuer à l’agent.

Voir le code source

​Méthodes

​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

Méthodes

`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`