Add 'dsset' structure.

scheduler/appengine/engine/tq/tq.go

 // Copyright 2017 The LUCI Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
@@ skipping 340 matching lines @@
                 return
         }
 
         execCount, _ := strconv.Atoi(c.Request.Header.Get("X-AppEngine-TaskExecutionCount"))
         switch err = h.cb(c.Context, payload, execCount); {
         case err == nil:
                 httpReply(c, true, 200, "OK")
         case transient.Tag.In(err):
                 httpReply(c, false, 500, "Transient error: %s", err)
         default:
-                httpReply(c, false, 200, "Fatal error: %s", err) // return 200 to stop retries
+                httpReply(c, false, 500, "Fatal error: %s", err) // return 200 to stop retries

[tandrii(chromium), 2017/07/21 13:42:52]

btw, why this?

[Vadim Sh., 2017/07/24 00:30:18]

Forgot to undo before sending the CL :) Shouldn't be here.

         }
 }
 
 func httpReply(c *router.Context, ok bool, code int, msg string, args ...interface{}) {
         body := fmt.Sprintf(msg, args...)
         if !ok {
                 logging.Errorf(c.Context, "%s", body)
         }
         http.Error(c.Writer, body, code)
 }
@@ skipping 33 matching lines @@
                 return nil, fmt.Errorf("no task body given")
         }
 
         task := reflect.New(tp.Elem()).Interface().(proto.Message)
         if err := jsonpb.Unmarshal(bytes.NewReader(*env.Body), task); err != nil {
                 return nil, err
         }
 
         return task, nil
 }