h = self.readSRPMHeader(srpm)

          data = koji.get_header_fields(h,['name','version','release','epoch'])

          data['task_id'] = self.id

          extra_arches = None

          self.logger.info("Reading package config for %(name)s" % data)

          pkg_cfg = self.session.getPackageConfig(dest_tag,data['name'],event=self.event_id)

                                              parent=self.id)

          # wait for subtask to finish

          result = self.wait(task_id)[task_id]

          srpm = result['srpm']

          return srpm

          brootid = broot.id

          log_files = glob.glob('%s/*.log' % broot.resultdir())

          broot.expire()

          return {'srpm': "%s/%s" % (uploadpath, srpm_name),

                  'logs': ["%s/%s" % (uploadpath, os.path.basename(f))

                                          for f in log_files],

                  'brootid': brootid,

                 }

  class TagNotificationTask(BaseTaskHandler):

  from fnmatch import fnmatch

  import base64

  import time

  import sys

  import traceback

  import errno

                  rel_path = '../' * len(path_comps.split('/'))

                  os.symlink(rel_path + 'common', '%s/../common' % sourcedir)

          return sourcedir

  ## END kojikamid dup

  class TaskManager(object):