fix setJobPayload

This commit is contained in:
shoopea 2020-02-07 10:56:19 +08:00
parent c5dddf20f0
commit 5fab2a7fa6

2
job.go
View File

@ -166,8 +166,8 @@ func setJobPayloadJSONUnsafe(jobID64 int64, payload interface{}) error {
func setJobPayload(jobID64 int64, payload []byte) error {
muxObjJob.Lock()
return setJobPayloadUnsafe(jobID64, payload)
defer muxObjJob.Unlock()
return setJobPayloadUnsafe(jobID64, payload)
}
func setJobPayloadUnsafe(jobID64 int64, payload []byte) error {