
    <#(i                     j    d dl Z d dlZd dlmZ ddlmZ  ej        e          Z G d de          Z	dS )    N)web   )ControlHandlerc                   .    e Zd Zej        d             ZdS )ListWorkersc                   K   |                      ddt                    }|                      ddt                    }|                      dd          }|r{	 t          j        | j                            |                     d{V  nF# t          $ r9}d	| }t                              |           t          j
        d
|          d}~ww xY w|rQi }| j        j        j        j                                        D ]\  }}|j        ||<   |                     |           dS | j        j        r9|s7|| j        j        v r)|                     || j        j        |         i           dS |r.|                     |          st          j
        dd| d          |r)|                     || j        j        |         i           dS |                     | j        j                   dS )a  
List workers

**Example request**:

.. sourcecode:: http

  GET /api/workers HTTP/1.1
  Host: localhost:5555

**Example response**:

.. sourcecode:: http

  HTTP/1.1 200 OK
  Content-Length: 1526
  Content-Type: application/json; charset=UTF-8
  Date: Tue, 28 Jul 2015 01:32:38 GMT
  Etag: "fcdd75d85a82b4052275e28871d199aac1ece21c"
  Server: TornadoServer/4.0.2

  {
      "celery@worker1": {
          "active_queues": [
              {
                  "alias": null,
                  "auto_delete": false,
                  "binding_arguments": null,
                  "bindings": [],
                  "durable": true,
                  "exchange": {
                      "arguments": null,
                      "auto_delete": false,
                      "delivery_mode": 2,
                      "durable": true,
                      "name": "celery",
                      "passive": false,
                      "type": "direct"
                  },
                  "exclusive": false,
                  "name": "celery",
                  "no_ack": false,
                  "queue_arguments": null,
                  "routing_key": "celery"
              }
          ],
          "conf": {
              "CELERYBEAT_SCHEDULE": {},
              "CELERY_INCLUDE": [
                  "celery.app.builtins",
                  "__main__"
              ],
              "CELERY_SEND_TASK_SENT_EVENT": true,
              "CELERY_TIMEZONE": "UTC"
          },
          "registered": [
              "tasks.add",
              "tasks.echo",
              "tasks.error",
              "tasks.retry",
              "tasks.sleep"
          ],
          "stats": {
              "broker": {
                  "alternates": [],
                  "connect_timeout": 4,
                  "heartbeat": null,
                  "hostname": "127.0.0.1",
                  "insist": false,
                  "login_method": "AMQPLAIN",
                  "port": 5672,
                  "ssl": false,
                  "transport": "amqp",
                  "transport_options": {},
                  "uri_prefix": null,
                  "userid": "guest",
                  "virtual_host": "/"
              },
              "clock": "918",
              "pid": 90494,
              "pool": {
                  "max-concurrency": 4,
                  "max-tasks-per-child": "N/A",
                  "processes": [
                      90499,
                      90500,
                      90501,
                      90502
                  ],
                  "put-guarded-by-semaphore": false,
                  "timeouts": [
                      0,
                      0
                  ],
                  "writes": {
                      "all": "100.00%",
                      "avg": "100.00%",
                      "inqueues": {
                          "active": 0,
                          "total": 4
                      },
                      "raw": "1",
                      "total": 1
                  }
              },
              "prefetch_count": 16,
              "rusage": {
                  "idrss": 0,
                  "inblock": 211,
                  "isrss": 0,
                  "ixrss": 0,
                  "majflt": 6,
                  "maxrss": 26996736,
                  "minflt": 11450,
                  "msgrcv": 4968,
                  "msgsnd": 1227,
                  "nivcsw": 1367,
                  "nsignals": 0,
                  "nswap": 0,
                  "nvcsw": 1855,
                  "oublock": 93,
                  "stime": 0.414564,
                  "utime": 0.975726
              },
              "total": {
                  "tasks.add": 1
              }
          },
          "timestamp": 1438049312.073402
      }
  }

:query refresh: run inspect to get updated list of workers
:query workername: get info for workername
:query status: only get worker status info
:reqheader Authorization: optional OAuth token to authenticate
:statuscode 200: no error
:statuscode 401: unauthorized request
        refreshF)defaulttypestatus
workernameN)r
   )r   zFailed to update workers: i  i  zUnknown worker '')get_argumentboolasynciowaitapplicationupdate_workers	Exceptionloggererrorr   	HTTPErroreventsstateworkersitemsalivewrite	is_worker)	selfr	   r   r   emsginfonameworkers	            R/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/flower/api/workers.pygetzListWorkers.get   s     Z ##Iu4#HH""8U"FF&&|T&BB
 	..l4#3#B#Bj#B#Y#YZZZZZZZZZZ . . .6166S!!!mC---.
  	D $ 0 7 = E K K M M * *f#\T

JJtF# 	G 	d.666JJ
D$4$<Z$HIJJJF 	GdnnZ88 	G-%E
%E%E%EFFF 	1JJ
D$4$<Z$HIJJJJJJJt'/00000s   3B 
C4C		CN)__name__
__module____qualname__r   authenticatedr'        r&   r   r      s6        j1 j1 j1 j1 j1r-   r   )
r   loggingtornador   controlr   	getLoggerr(   r   r   r,   r-   r&   <module>r2      s            # # # # # #		8	$	$l1 l1 l1 l1 l1. l1 l1 l1 l1 l1r-   