def METHOD_NAME(self, _process_bulk_chunk):
    actions = ({"x": i} for i in range(100))
    results = list(
        helpers.parallel_bulk(
            Elasticsearch("http://localhost:9200"),
            actions,
            thread_count=10,
            chunk_size=2,
        )
    )
    assert len(set([r[1] for r in results])) > 1