Run a command on the remote host and return the standard output and error as a tuple. Extended from pywinrm to support passing env an

Assert that the provided command matches exactly one format string from the provided list.

Assert that there are no stray / zombie processes left with the provided command line string.

Decrement gauge value.

Delete the provided key. By default, value is deleted from a namespace local to the pack/class. If you want to delete a glob

Download the pack and move it to /opt/stackstorm/packs. :param abs_repo_base: Path where the pack should be installed to. :type abs_repo

Augment instance "status" attribute with number of seconds which have elapsed for all the executions which are in running state and execution

Check if all listed indexes are healthy: they should be reachable, return valid JSON objects, and yield more than one result.

Returns the action object from db given a string ref. :param ref: Reference to the trigger type db object. :type ref: ``str`` :para

Return a list of base paths which are searched for action aliases. :rtype: ``list``

Determines the callable which will perform the cast given a string representation of the type. :param cast_type: Type of the cast to per

Retrieve config for a particular pack. :return: Config object if config is found, ``None`` otherwise. :rtype: :class:`.Conte

Return raw fixture content for the provided fixture path. :param fixture_path: Fixture path relative to the tests/fixtures/ director

Return a list of all the supported format strings. :rtype: ``list`` of ``str``

Retrieve member if for the current process. :rtype: ``bytes``

Return path to the Python binary for the provided pack. :param pack: Pack name. :type pack: ``str``

Method which returns reference to the service class instance.

Returns the trigger type object from db given a string ref. :param ref: Reference to the trigger type db object. :type ref: ``str``

Increment gauge value.

Inject immutable parameters from the alias definiton on the execution parameters. Jinja expressions will be resolved.

Lowercase the provided value. In case of a list, all the string item values are lowercases and in case of a dictionary, all of the strin

Factory function which returns a function for reading from a stream (stdout / stderr). This function writes read data into a buffer and stor

Process the model dictionary and mask secret values. NOTE: This method results in one addition "get one" query where we retrieve cor

Return controller class instance and controller method callbacle for the provided operation id. :rtype: ``tuple``

Poll 3rd party system for new information.

Purge task execution output objects. :param timestamp: Exections older than this timestamp will be deleted. :type timestamp: ``datetime.

Purge workflow execution output objects. :param timestamp: Exections older than this timestamp will be deleted. :type timestamp: ``datet

Copy a file or folder to remote host. :param local_path: Path to local file or dir. Must be shlex quoted. :type local_path:

Function which reencodes each item in the provided list replacing unicode surrogate escape sequences using actual unicode values.

:return: Tuple, Number of rules registered, overridden :rtype: ``tuple``

Register configs for all the available packs.

Discover all the packs in the provided directory and register sensors from all of the discovered packs. :return: Number of s

Method which converts DB object to API object and performs any additional filtering.

Note: This function is based on paramiko's exec_command() method. :param timeout: How long to wait (in seconds) for the comm

Set a value for the provided key. By default, value is set in a namespace local to the pack/class. If you want to set a glob

Serialize database model to a dictionary. :param mask_secrets: True to mask secrets in the resulting dict. :type mask_secret

Function which verifies that RBAC is correctly set up and configured.

Clean up any action execution in the deprecated policy-delayed status. Associated entries in the scheduling queue will be removed and

Try to consume stderr data from chan if it's receive ready.

Try to consume stdout data from chan if it's receive ready.

Convert a `datetime` object to number of microseconds since epoch representation (which will be stored in MongoDB). This is the rever

Note: We also create RuleEnforcementDB for rules which failed to match due to an exception. Without that, only way for users to find