[GH-ISSUE #589] asynq.ProcessIn not delay work #284

New issue

Closed

opened 2026-03-02 05:20:11 +03:00 by kerem · 2 comments

kerem commented

2026-03-02 05:20:11 +03:00

Owner

Originally created by @kuangshp on GitHub (Dec 23, 2022).
Original GitHub issue: https://github.com/hibiken/asynq/issues/589

Originally assigned to: @hibiken on GitHub.

package main

import (
	"encoding/json"
	"fmt"
	"github.com/hibiken/asynq"
	"time"
)

type Person struct {
	Id   int    `json:"id"`
	Name string `json:"name"`
}

func main() {
	client := asynq.NewClient(asynq.RedisClientOpt{
		Addr:     "127.0.0.1:6379",
		Password: "",
		DB:       0,
	})
	defer client.Close()

	person1, _ := json.Marshal(Person{Id: 1, Name: "hello"})
	task1 := asynq.NewTask("order", person1)
	var task1Info, _ = client.Enqueue(task1, asynq.ProcessIn(1*time.Hour))
	var p Person
	json.Unmarshal(task1Info.Payload, &p)
	fmt.Println(p.Name)
	time.Sleep(24 * time.Hour)
}

I want to use this package to do the task delay execution, but the execution is instantaneous, I don't know what is wrong

Originally created by @kuangshp on GitHub (Dec 23, 2022). Original GitHub issue: https://github.com/hibiken/asynq/issues/589 Originally assigned to: @hibiken on GitHub. ```go package main import ( "encoding/json" "fmt" "github.com/hibiken/asynq" "time" ) type Person struct { Id int `json:"id"` Name string `json:"name"` } func main() { client := asynq.NewClient(asynq.RedisClientOpt{ Addr: "127.0.0.1:6379", Password: "", DB: 0, }) defer client.Close() person1, _ := json.Marshal(Person{Id: 1, Name: "hello"}) task1 := asynq.NewTask("order", person1) var task1Info, _ = client.Enqueue(task1, asynq.ProcessIn(1*time.Hour)) var p Person json.Unmarshal(task1Info.Payload, &p) fmt.Println(p.Name) time.Sleep(24 * time.Hour) } ``` I want to use this package to do the task delay execution, but the execution is instantaneous, I don't know what is wrong