mirror of
https://github.com/hibiken/asynq.git
synced 2025-04-19 23:30:20 +08:00
Merge ca52ef8c8da89d0d436fe432c986d21371f36921 into c327bc40a28e4db45195cfe082d88faa808ce87d
This commit is contained in:
commit
8bd2365f85
5
asynq.go
5
asynq.go
@ -549,3 +549,8 @@ func (w *ResultWriter) Write(data []byte) (n int, err error) {
|
|||||||
func (w *ResultWriter) TaskID() string {
|
func (w *ResultWriter) TaskID() string {
|
||||||
return w.id
|
return w.id
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// QueueName returns the name of the queue the task belongs to.
|
||||||
|
func (w *ResultWriter) QueueName() string {
|
||||||
|
return w.qname
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user