var futures []workflow.Future
for _, id := range orderIds {
future := workflow.ExecuteActivity(wctx, UpdateOrderStatusActivity, id)
logger.Get(ctx).Infof("Finished the order status update for order id %s ", id.String())
futures = append(futures, future)
}
for _, f := range futures {
var orderStatusUpdate map[string]bool
errorWhileGettingFuture := f.Get(wctx, &orderStatusUpdate)
if errorWhileGettingFuture != nil {
logger.Get(ctx).Errorf("[FUTURE GET] Error while the order status update for order : error %s ", errorWhileGettingFuture)
}
}
This part is actually causing a memory leak in Go, using this future.
And using PPROF seems internal haven’t been able to debug this.
