This commit is contained in:
shoopea 2020-01-26 14:53:25 +08:00
parent 8796ab916d
commit af3277d65a

6
job.go
View File

@ -145,7 +145,11 @@ func setJobTimeout(jobID64 int64, d time.Duration) error {
} }
func setJobPayload(jobID64 int64, payload []byte) error { func setJobPayload(jobID64 int64, payload []byte) error {
var zb bytes.Buffer var (
zb bytes.Buffer
zpayload []byte
zipped int
)
if len(payload) > 10000 { if len(payload) > 10000 {
zw := zlib.NewWriter(&zb) zw := zlib.NewWriter(&zb)