@task(routing_key="low_priority", queue="low_priority", acks_late=True)
def long_running():
    import os
    from time import sleep

    while not os.path.isfile('/Users/romanko/stop'):
        logger.info('no file: waiting 5 seconds')
        sleep(5)

    logger.info('file exists: exiting')