Source code for pypushflow.concurrent.interrupt

"""Utilities to terminate pool tasks"""




[docs]
class StopPypushflowTask(Exception):
    pass