def __init__()

in atomresponder/master_importer.py [0:0]

• 7 lines of code
• 3 McCabe index (conditional complexity)

    def __init__(self, *args, **kwargs):
        super(MasterImportResponder, self).__init__(*args, **kwargs)
        self._pika_client = None

        #set up exchange on startup. this also means we terminate if we can't connect to the broker.
        if "CI" not in os.environ:
            (conn, channel) = self.setup_pika_channel()
            channel.close()
            conn.close()