def params()

in elastic/shared/parameter_sources/initial_indices.py [0:0]

• 24 lines of code
• 5 McCabe index (conditional complexity)

    def params(self):
        if self.current_index == 0:
            self._client_count = self._params["client_count"]
            self._client_index = self._params["client_index"]
            if self._client_count <= 0:
                self._complete = True
                raise StopIteration
            self.indices_per_client = self._params["initial_indices_count"] / self._client_count
        self.current_index += 1
        if self.current_index > self.indices_per_client:
            self._complete = True
            raise StopIteration
        lines = []
        client_index = self._client_index
        for i in range(100):
            lines.append('{"create":{"_index":"%s-%d-%d"}}\n' % (self._params["name"], client_index, self.current_index))
            lines.append('{"@timestamp":"2%03d-01-01T12:10:30Z"}\n' % i)

        params = self._params.copy()
        params["body"] = "".join(lines)
        params["bulk-size"] = 100
        params["unit"] = "docs"
        params["action-metadata-present"] = True
        params["param-source-stats"] = {"client": client_index}
        return params