example_client_named_arg_test.go

// Copyright (c) 2019 Sick Yoon
// This file is part of gocelery which is released under MIT license.
// See file LICENSE for full license details.

package gocelery

import (
	"context"
	"log"
	"math/rand"
	"reflect"
	"time"

	"github.com/redis/go-redis/v9"
)

func Example_clientWithNamedArguments() {
	connectOpions, err := redis.ParseURL("redis://")
	if err != nil {
		panic(err)
	}

	client := redis.NewClient(connectOpions)

	// initialize celery client
	cli, _ := NewCeleryClient(
		NewRedisBroker(client),
		&RedisCeleryBackend{UniversalClient: client},
		1,
	)

	// prepare arguments
	taskName := "worker.add"
	argA := rand.Intn(10)
	argB := rand.Intn(10)

	// run task
	asyncResult, err := cli.DelayKwargs(
		context.Background(),
		taskName,
		map[string]interface{}{
			"a": argA,
			"b": argB,
		},
	)
	if err != nil {
		panic(err)
	}

	// get results from backend with timeout
	res, err := asyncResult.Get(context.Background(), 10*time.Second)
	if err != nil {
		panic(err)
	}

	log.Printf("result: %+v of type %+v", res, reflect.TypeOf(res))

}