@when(u'a task has drained')
def when_a_task_has_drained(context):
    drain_lib.TestDrainMethod.mark_arbitrary_task_as_safe_to_kill()
Tell the TestDrainMethod to mark a task as safe to kill.
dataset/ETHPy150Open Yelp/paasta/paasta_itests/steps/bounces_steps.py/when_a_task_has_drained