old_contents: from subprocess import check_call, Popen, PIPE, CalledProcessError
  
  from .queued_drmaa import DrmaaQueueManager
  
  import logging
  log = logging.getLogger(__name__)
  
  
  class XsedeDrmaaQueueManager(DrmaaQueueManager):
      """
      DRMAA backed queue manager for XSEDE (to run the XSEDE job/user reporting
      script after submission).
  
      TODO: A generalized callback framework for executing things at various
      points in the job lifecycle.
      """
      manager_type = "queued_drmaa_xsede"
  
      def launch(self, job_id, command_line, submit_params={}, dependencies_description=None, env=[]):
          super(XsedeDrmaaQueueManager, self).launch(
              job_id,
              command_line,
              submit_params=submit_params,
              dependencies_description=dependencies_description,
              env=env
          )
          try:
              check_call([
                  'gateway_submit_attributes',
                  '-gateway_user',
                  submit_params.get('user_email', 'unknown@galaxyproject.org'),
                  '-submit_time',
                  check_output(['date', '+%F %T %:z']).strip(),
                  '-jobid',
                  self._external_ids[job_id]
              ])
          except (OSError, IOError, CalledProcessError) as exc:
              log.exception('Failed to call gateway_submit_attributes:')
  
  
  def check_output(args):
      """Pipe-safe (and 2.6 compatible) version of subprocess.check_output
      """
      proc = Popen(args, stdout=PIPE)
      out = proc.communicate()[0]
      if proc.returncode:
          raise CalledProcessError(proc.returncode, args, output=out)
      return out
  
new_contents: from subprocess import check_call, Popen, PIPE, CalledProcessError
  
  from .queued_drmaa import DrmaaQueueManager
  
  import logging
  log = logging.getLogger(__name__)
  
  
  class XsedeDrmaaQueueManager(DrmaaQueueManager):
      """
      DRMAA backed queue manager for XSEDE (to run the XSEDE job/user reporting
      script after submission).
  
      TODO: A generalized callback framework for executing things at various
      points in the job lifecycle.
      """
      manager_type = "queued_drmaa_xsede"
  
      def launch(self, job_id, command_line, submit_params={}, dependencies_description=None, env=[]):
          super(XsedeDrmaaQueueManager, self).launch(
              job_id,
              command_line,
              submit_params=submit_params,
              dependencies_description=dependencies_description,
              env=env
          )
          try:
              check_call([
                  'gateway_submit_attributes',
                  '-gateway_user',
                  submit_params.get('user_email', 'unknown@galaxyproject.org'),
                  '-submit_time',
                  check_output(['date', '+%F %T %:z']).strip(),
                  '-jobid',
                  self._external_ids[job_id]
              ])
          except (OSError, IOError, CalledProcessError):
              log.exception('Failed to call gateway_submit_attributes:')
  
  
  def check_output(args):
      """Pipe-safe (and 2.6 compatible) version of subprocess.check_output
      """
      proc = Popen(args, stdout=PIPE)
      out = proc.communicate()[0]
      if proc.returncode:
          raise CalledProcessError(proc.returncode, args, output=out)
      return out
  
subject: Remove unused declaration of exception instance.