Voir le code source
| Arguments | Description |
|---|---|
api | Objet API à utiliser pour adresser des requêtes au backend. |
config | Dictionnaire de configuration de l’agent. |
| Attributes | Description |
|---|---|
num_running_jobs | Renvoie le nombre de jobs, sans inclure les planificateurs. |
num_running_schedulers | Renvoie uniquement le nombre de planificateurs. |
thread_ids | Renvoie une liste des clés correspondant aux ID des threads en cours d’exécution pour l’agent. |
Méthodes
check_sweep_state
fail_run_queue_item
finish_thread_id
get_job_and_queue
initialized
loop
| Exceptions levées | Description |
|---|---|
KeyboardInterrupt | si l’agent reçoit une demande d’arrêt. |
name
pop_from_queue
| Arguments | Description |
|---|---|
queue | File d’attente depuis laquelle extraire l’élément. |
| Renvoie | Description |
|---|---|
| Élément extrait de la file d’attente. |
| Exceptions levées | Description |
|---|---|
Exception | en cas d’erreur lors de l’extraction depuis la file d’attente. |
print_status
run_job
| Arguments | Description |
|---|---|
job | Job à exécuter. |
task_run_job
update_status
| Arguments | Description |
|---|---|
status | Statut à attribuer à l’agent. |