def _parse_connectors()

in connectors/services/base.py [0:0]

• 25 lines of code
• 8 McCabe index (conditional complexity)

    def _parse_connectors(self):
        connectors = {}
        configured_connectors = deepcopy(self.config.get("connectors"))
        if configured_connectors is not None:
            for connector in configured_connectors:
                connector_id = connector.get("connector_id")
                if not connector_id:
                    self.logger.warning(
                        f"Found invalid connector configuration. Connector id is missing for {connector}"
                    )
                    continue

                connector_id = str(connector_id)
                if connector_id in connectors:
                    self.logger.warning(
                        f"Found duplicate configuration for connector {connector_id}, overriding with the later config"
                    )
                connectors[connector_id] = connector

        if not connectors:
            if "connector_id" in self.config and "service_type" in self.config:
                connector_id = str(self.config["connector_id"])
                connectors[connector_id] = {
                    "connector_id": connector_id,
                    "service_type": self.config["service_type"],
                }

        return connectors