golden hour

/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__

File/Folder	Size	Actions
__init__.cpython-310.pyc	2.72 KB
docker_events.cpython-310.pyc	2.3 KB
fluent.cpython-310.pyc	2.13 KB
http_logstash.cpython-310.pyc	2.67 KB
ircbot.cpython-310.pyc	9.65 KB
junos_syslog.cpython-310.pyc	9.43 KB
libvirt_events.cpython-310.pyc	18.74 KB
logentries.cpython-310.pyc	5.03 KB
logstash_engine.cpython-310.pyc	1.83 KB
napalm_syslog.cpython-310.pyc	10.34 KB
reactor.cpython-310.pyc	846 B
redis_sentinel.cpython-310.pyc	2.9 KB
script.cpython-310.pyc	3.53 KB
slack.cpython-310.pyc	25.81 KB
slack_bolt_engine.cpython-310.pyc	30.07 KB
sqs_events.cpython-310.pyc	4.36 KB
stalekey.cpython-310.pyc	3.36 KB
test.cpython-310.pyc	1.01 KB
thorium.cpython-310.pyc	532 B
webhook.cpython-310.pyc	2.95 KB

Edit: script.cpython-310.pyc

�����xe����������������������@���sp���d�Z�ddlZddlZddlZddlZddlZddlZddlZddl	m
Z
�e�e�Z
dd��Zdd��Zd
dd�ZdS�)a���
Send events based on a script's stdout

Example Config

.. code-block:: yaml

engines:
      - script:
          cmd: /some/script.py -a 1 -b 2
          output: json
          interval: 5
          onchange: false

Script engine configs:

cmd
    Script or command to execute

output
    Any available saltstack deserializer

interval
    How often in seconds to execute the command

onchange
    .. versionadded:: 3006.0

Only fire an event if the tag-specific output changes. Defaults to False.
�����N)�CommandExecutionErrorc�����������������c���s�����t�|�jjd�E�dH��dS�)z'
    Generator that returns stdout
    �����N)�iter�stdout�readline)�proc��r����G/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/script.py�_read_stdout-���s����r
���c�����������������C���s6���t�j�t�}zt||��W�S��ty���td�|����w�)zM
    Helper to return known serializer based on
    pass output argument
    z/Unknown serializer `{}` found for output option)�salt�loader�serializers�__opts__�getattr�AttributeErrorr����format)�outputr
���r���r���r	����_get_serializer4���s�����r����json����Fc��������������
���C���s���zt��|��}�W�n�ty���t��t|���}�Y�nw�t�d|���t|�}t�d�dkr5t	j
j�ttd��j
}ntd�}|r=i�}	�z�zutj|�tjtjd�}t�d|j��t|�D�]E}t�|��|�|�}	|	�d	d
�}
|	�di��}|ryd|vrytd�|d<�|
r�|r�|
|v�r�||
�|kr�qUt�d
|
��||
|d��|r�|||
<�qUt�d|j��|j����|���}|r�t�||���W�n�tjy��}
�zt�|
��W�Y�d
}
~
nd
}
~
ww�W�|jd
u�r�|����n|jd
u�r�|����w�w�t�|��q>)aC��
    Parse stdout of a command and generate an event

The script engine will scrap stdout of the
    given script and generate an event based on the
    presence of the 'tag' key and its value.

If there is a data obj available, that will also
    be fired along with the tag.

Example:

Given the following json output from a script:

.. code-block:: json

{ "tag" : "lots/of/tacos",
                "data" : { "toppings" : "cilantro" }
                }

This will fire the event 'lots/of/tacos'
        on the event bus with the data obj as is.

:param cmd: The command to execute
    :param output: How to deserialize stdout of the script
    :param interval: How often to execute the script
    :param onchange: Only fire an event if the tag-specific output changes
    zscript engine using command %sZ__roleZmasterZsock_dirz
event.sendT)r����stderrzStarting script with pid %d�tagN�data�idz&script engine firing event with tag %s)r���r���zClosing script with pid %d) �shlex�splitr����str�log�debugr���r����getr����utils�eventZget_master_eventZ
fire_eventZ__salt__�
subprocess�Popen�PIPE�STDOUT�pidr
���Zdeserialize�infor����close�wait�CalledProcessError�error�poll�	terminate�time�sleep)�cmdr����intervalZonchangeZ
serializerZfire_master�eventsr���Z	raw_eventr!���r���r����rc�er���r���r	����startB���sp������
�

�
����
�
�
�
�r5���)r���r���F)�__doc__Zloggingr���r"���r.���Zsalt.loaderr���Zsalt.utils.eventZsalt.utils.processZsalt.exceptionsr���Z	getLogger�__name__r���r
���r���r5���r���r���r���r	����<module>���s����