def determine_scribereader_envs(self, components, cluster):
        envs = []
        for component in components:
            # If a component has a 'source_env', we use that
            # otherwise we lookup what scribe env is associated with a given cluster
            env = LOG_COMPONENTS[component].get('source_env', self.cluster_to_scribe_env(cluster))
            envs.append(env)
        return set(envs)
Writes on this channel until select no longer reports it as writable.
dataset/ETHPy150Open Yelp/paasta/paasta_tools/cli/cmds/logs.py/ScribeLogReader.determine_scribereader_envs--crossover with--dataset/ETHPy150Open babble/babble/include/jython/Lib/test/test_select_new.py/AsynchronousHandler.write