def get_thread_dependency_string()

in workflows-generator/ComposerDagGenerator.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    def get_thread_dependency_string(self, threads, level_id):
        thread_names = []
        for thread in threads:
            thread_name = "tg_level_" + level_id + "_Thread_" + thread.get("THREAD_ID")
            thread_names.append(thread_name)
        return "\n           ".join(thread_names)