digdag's `http_call>` operator sample

main.dig

+run_workflow:
  http_call>: http://$(ip):8000/http_call_dig
  retry: false
  _retry: 2

server.rb

require 'webrick'
require 'cgi'

s = WEBrick::HTTPServer.new(
  :Port => 8000,
  :HTTPVersion => WEBrick::HTTPVersion.new('1.1'),
)

s.mount_proc('/http_call_dig') do |req, res|
  res.status = 200
  res['Content-Type'] = 'application/x-yaml'
  res.body = <<~YAML
  +task_1:
    echo>: "hello ${session_time}"

  +task_2:
    fail>: "fail!"
  YAML
end

Signal.trap('INT'){s.shutdown}
s.start