def schedule_function(queue_name, function_name, *args, **kwargs):
    """
    Schedule a function named `function_name` to be run by workers on
    the queue `queue_name` with *args and **kwargs as specified by that
    function.
    """
    body = create_request_body(function_name, *args, **kwargs)
    if getattr(settings, 'BEANSTALK_DISPATCH_EXECUTE_SYNCHRONOUSLY', False):
        execute_function(json.loads(body))
    else:
        connection = boto.connect_sqs(
            settings.BEANSTALK_DISPATCH_SQS_KEY,
            settings.BEANSTALK_DISPATCH_SQS_SECRET)
        queue = connection.get_queue(queue_name)
        if not queue:
            queue = connection.create_queue(queue_name)
        message = boto.sqs.message.Message()
        message.set_body(body)
        queue.write(message)
def schedule_function ( queue_name , function_name , * args , ** kwargs ) : body = create_request_body ( function_name , * args , ** kwargs ) if getattr ( settings , 'BEANSTALK_DISPATCH_EXECUTE_SYNCHRONOUSLY' , False ) : execute_function ( json . loads ( body ) ) else : connection = boto . connect_sqs ( settings . BEANSTALK_DISPATCH_SQS_KEY , settings . BEANSTALK_DISPATCH_SQS_SECRET ) queue = connection . get_queue ( queue_name ) if not queue : queue = connection . create_queue ( queue_name ) message = boto . sqs . message . Message ( ) message . set_body ( body ) queue . write ( message )
Schedule a function named `function_name` to be run by workers on
    the queue `queue_name` with *args and **kwargs as specified by that
    function.