- analyzers

      - converter

      - database

      - model

      - monitor

      - queue

  import fedmsg.consumers

  import time

  import kiskadee.plugins

  import kiskadee.queue

          source_version = ''.join([source_data.get('version'), '.tar.gz'])

          homepage = source_data.get('meta').get('homepage')

          url = ''.join([homepage, '/archive/', source_version])

  class AnityaConsumer(fedmsg.consumers.FedmsgConsumer):

  from debian.deb822 import Sources

  import subprocess

  import kiskadee.queue

  RUNNING = True

      def get_sources(self, source_data):

          """Download packages from some debian mirror."""

          path = tempfile.mkdtemp()

              url = self._dsc_url(source_data)

              try:

                  subprocess.check_output(['dget', url])

  import kiskadee.analyzers

  import kiskadee.model

  import kiskadee.database

  import kiskadee.converter

  running = True

          reports = []

          path = tempfile.mkdtemp()

          shutil.unpack_archive(compressed_source, path)

              kiskadee.logger.debug('ANALYSIS: Unpacked!')

              analyzers = plugin.analyzers()

              for analyzer in analyzers: