mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
Starts up new tasks of nothing running
This commit is contained in:
@@ -92,6 +92,7 @@ func ProxyFunc(w http.ResponseWriter, req *http.Request) {
|
|||||||
fmt.Println("err type:", etype)
|
fmt.Println("err type:", etype)
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
if etype == reflect.TypeOf(net.OpError{}) { // couldn't figure out a better way to do this
|
if etype == reflect.TypeOf(net.OpError{}) { // couldn't figure out a better way to do this
|
||||||
|
fmt.Println("It's a network error, so we're going to start new task.")
|
||||||
// start new worker
|
// start new worker
|
||||||
payload := map[string]interface{}{
|
payload := map[string]interface{}{
|
||||||
"token": route.Token,
|
"token": route.Token,
|
||||||
|
|||||||
Reference in New Issue
Block a user