Skip to main content

Celery Timeout decorator

Project description

Process Timer

Installation

From source code:

python setup.py install

From pypi:

pip install process-timer

Usage

    import time
    from process_timer import timeout

    @timeout(5)
    def mytest():
        print("Start")
        for i in range(1,10):
            time.sleep(1)
            print(f"{i} seconds have passed")

    if __name__ == '__main__':
        mytest()

Specify an alternate exception to raise on timeout:

    import time
    from process_timer import timeout

    @timeout(5, timeout_exception=StopIteration)
    def mytest():
        print("Start")
        for i in range(1,10):
            time.sleep(1)
            print(f"{i} seconds have passed")

    if __name__ == '__main__':
        mytest()

Multithreading

By default, timeout-decorator uses signals to limit the execution time of the given function. This appoach does not work if your function is executed not in a main thread (for example if it's a worker thread of the web application). There is alternative timeout strategy for this case - by using multiprocessing. To use it, just pass use_signals=False to the timeout decorator function:

    import time
    from process_timer import timeout

    @timeout(5, use_signals=False)
    def mytest():
        print("Start")
        for i in range(1,10):
            time.sleep(1)
            print(f"{i} seconds have passed")

    if __name__ == '__main__':
        mytest()

Warning Make sure that in case of multiprocessing strategy for timeout, your function does not return objects which cannot be pickled, otherwise it will fail at marshalling it between master and child processes.

Acknowledgement

    Timeout Decorator - https://github.com/pnpnpn/timeout-decorator
    http://www.saltycrane.com/blog/2010/04/using-python-timeout-decorator-uploading-s3/
    https://code.google.com/p/verse-quiz/source/browse/trunk/timeout.py

Contribute

I would love for you to fork and send me pull request for this project. Please contribute.

License

This software is licensed under the MIT license

See License file

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for process-timer, version 1.1.1
Filename, size File type Python version Upload date Hashes
Filename, size process_timer-1.1.1-py3-none-any.whl (5.6 kB) File type Wheel Python version py3 Upload date Hashes View
Filename, size process-timer-1.1.1.tar.gz (4.4 kB) File type Source Python version None Upload date Hashes View

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page