AWS SWF : kill stuck workflow executions

gistfile1.txt

require 'rubygems'
require 'aws-sdk'
require 'pry'

class SwfManager

  def client
    credentials = Aws::SharedCredentials.new(profile_name: 'default')
    swf = Aws::SWF::Client.new(
      region: 'us-east-1',
      credentials: credentials
      )
    end

  def list_workflow domain
    p client
    p domain
    resp = client.list_open_workflow_executions({
      domain: domain, # required
      start_time_filter: { # required
        latest_date: Time.now, # required
        oldest_date: (Date.today - 90).to_time,
      }
      # execution_filter: {
      #   workflow_id: "WorkflowId", # required
      # },
    })

    resp.execution_infos.each do |wf|
      id =  wf.execution.workflow_id
      purge_workflow domain, id
    end

  end


  def purge_workflow domain, workflow_id
    resp = client.terminate_workflow_execution({
      domain: domain,
      workflow_id: workflow_id,
      reason: "killed via script",
    })
    p "domain : id : deleted : #{domain} : #{workflow_id} : #{resp}"
  end
end

manager = SwfManager.new
manager.list_workflow "OptionHtmlParseDomain"
#manager.purge_workflow "OptionHtmlParseDomain", "WBA5A7C56GG146159"