def partition()

in eventdata/parameter_sources/elasticlogs_bulk_source.py [0:0]

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

    def partition(self, partition_index, total_partitions):
        if self._params.get("id_type") != "seq":
            seed = partition_index * self._params["seed"] if "seed" in self._params else None
            random.seed(seed)
        new_params = copy.deepcopy(self.orig_args[1])
        new_params["client_id"] = partition_index
        new_params["client_count"] = total_partitions
        return ElasticlogsBulkSource(self.orig_args[0], new_params, **self.orig_args[2])