redis_cluster_instances_create:
  salt.state:
    - tgt: '*redis*'
    - highstate: True

redis_cluster_setup_masters_{{ cluster }}:
  salt.runner:
    - name: salt.cmd
    - fun: cmd.run
    - args:
      - srv/salt/orch/redis_cluster/usr/bin/redis-trib.rb create {% for shard in shards %}{{ shard['master'] }} {% endfor %}
    - kwargs:
      unless: srv/salt/orch/redis_cluster/usr/bin/redis-trib.rb info {{ shards[0]['master'] }} | grep 'cluster_state:ok'
    - require:
      - salt: redis_cluster_instances_create

lab-orchestrator_master:
----------
          ID: redis_cluster_instances_create
    Function: salt.state
      Result: True
     Comment: States ran successfully. No changes made to lab-redis04, lab-redis01, lab-redis02, lab-redis03.
     Started: 09:54:57.811313
    Duration: 14223.204 ms
     Changes:
----------
          ID: redis_cluster_setup_masters_pdnocg
    Function: salt.runner
        Name: salt.cmd
      Result: False
     Comment: Exception occurred in runner salt.cmd: Traceback (most recent call last):
                File "/usr/lib/python2.7/site-packages/salt/client/mixins.py", line 392, in _low
                  data['return'] = self.functions[fun](*args, **kwargs)
              TypeError: cmd() takes at least 1 argument (0 given)
     Started: 09:55:12.034716
    Duration: 1668.345 ms
     Changes: