|
51 | 51 | const ( |
52 | 52 | defaultTaskPullingInterval = time.Second * 3 |
53 | 53 | defaultStatusReportingInterval = time.Second * 10 |
54 | | - defaultProxyRequestTimeout = time.Second * 60 |
55 | | - defaultProxyRequestRetries = 5 |
| 54 | + defaultProxyRequestTimeout = time.Second * 30 |
| 55 | + defaultProxyRequestRetries = 3 |
56 | 56 | ) |
57 | 57 |
|
58 | 58 | type ( |
@@ -264,11 +264,14 @@ func startTasks(tasks []task.Task, runtimes map[string]runtime.Runtime, logger l |
264 | 264 | t := agentTasks[i] |
265 | 265 | logger.Info("executing agent task", "tid", t.Metadata.Workflow) |
266 | 266 | txn := newTransaction(monitor, t.Type, t.Metadata.Workflow, t.Metadata.ReName) |
267 | | - if err := executeAgentTask(&t, logger); err != nil { |
268 | | - logger.Error(err.Error()) |
269 | | - noticeError(txn, err, logger) |
270 | | - } |
271 | | - endTransaction(txn, logger) |
| 267 | + go func(tid string) { |
| 268 | + if err := executeAgentTask(&t, logger); err != nil { |
| 269 | + logger.Error(err.Error()) |
| 270 | + noticeError(txn, err, logger) |
| 271 | + } |
| 272 | + endTransaction(txn, logger) |
| 273 | + logger.Info("finished agent task", "tid", t.Metadata.Workflow) |
| 274 | + }(t.Metadata.Workflow) |
272 | 275 | } |
273 | 276 |
|
274 | 277 | // process creation tasks |
|
0 commit comments