tasks_remove.py 文件源码

def action_proc_remove(config):

    log.warning("  - Trying to connect with server...")

    url = '%s://%s' % (config.broker_type, config.target)

    with Connection(url) as conn:
        in_queue = conn.SimpleQueue('celery')

        # Get remote process
        for _ in get_remote_messages(config, in_queue, False):
            pass

        log.error("   - All tasks removed from '%s'" % config.target)