executor: pf_api_poll
input:
  i_task_id: ""
  i_message: "Completed"
  i_progress: 100
  i_retry: 40
  i_delay: 3
steps:
- type: pf_api_action
  url: "pfqueue/task/{{.input.i_task_id}}/status/poll"
  # wait two minutes by default
  retry: "{{.input.i_retry}}"
  delay: "{{.input.i_delay}}"
  assertions:
    - result.pf_api_action_json.message ShouldEqual "{{.input.i_message}}"
    - result.pf_api_action_json.progress ShouldEqual "{{.input.i_progress}}"
  vars:
    poll_temp:
       from: result.pf_api_action_

output: 
  pf_api_poll_: "{{.poll_temp}}"
