import errno

  import hashlib

  import logging

  import os

  import re

                  else:

                      self.logger.info("Lingering task %r (pid %r)" % (id, pid))

      def getNextTask(self):

          self.ready = self.readyForTask()

          self.session.host.updateHost(self.task_load, self.ready)

          if not self.ready:

              self.logger.info("Not ready for task")

              return False

              h_refused = refusals.get(task['task_id'], {})

              for host in self.hosts_by_bin.get(task['_bin'], []):

                  if (host['ready'] and host['_ntasks'] < self.maxjobs and

                          host['capacity'] - host['_load'] > min_avail and

                          host['id'] not in h_refused):

                      task['_hosts'].append(host)

                           [(h['name'], "%(_rank).2f" % h) for h in task['_hosts']])

              for host in task['_hosts']:

                  if (host['capacity'] - host['_load'] > min_avail and

                      # add run entry

                      self.assign(task, host)

                      # update our totals and rank

              ('host.ready', 'ready'),

              ('host_config.arches', 'arches'),

              ('host_config.capacity', 'capacity'),

          )

          fields, aliases = zip(*fields)

                  'host_config.active IS TRUE',

              ],

              joins=[

              ]

          )