gistfile1.rb

def monitor_stale(flags = {})
    stale = Dor::WorkflowService.get_stale_queued_workflows('sdr', hours_ago: 24, limit: 1000)
    pp stale
    stale.each do |h|
      h[:repo] = 'sdr'
      ap({:h => h}) if flags[:debug]
      Dor::WorkflowService.update_workflow_status(h[:repo], h[:druid], h[:workflow], h[:step], 'waiting', expected: 'queued')      
    end
end