def is_draining(self, task):
        return task.id in (self.downed_task_ids | self.safe_to_kill_task_ids)
dataset/ETHPy150Open Yelp/paasta/paasta_tools/drain_lib.py/TestDrainMethod.is_draining/original