def mapper(self, line):
        _, artist, _ = line.strip().split()
        yield artist, 1
Test for initial control connection timeout
dataset/ETHPy150Open spotify/luigi/examples/top_artists.py/AggregateArtistsHadoop.mapper--crossover with--dataset/ETHPy150Open datastax/python-driver/tests/integration/standard/test_cluster.py/ClusterTests.test_raise_error_on_control_connection_timeout