diff options
| author | Jonathan Amsterdam <jba@google.com> | 2024-03-01 11:37:13 -0500 |
|---|---|---|
| committer | Jonathan Amsterdam <jba@google.com> | 2024-03-05 19:44:05 +0000 |
| commit | acdeec62f9ea6fe68e2b2379645635154a64fdf1 (patch) | |
| tree | c97064def76bf8c2c26a24fc263a1150a222348a /internal/postgres/versionstate.go | |
| parent | d5201754263e3874af3d2a0b59ea11d396fc6756 (diff) | |
| download | go-x-pkgsite-acdeec62f9ea6fe68e2b2379645635154a64fdf1.tar.xz | |
worker: display request state on main page
Add a RequestInfo.State field to record the current state of a request
for display.
Add a function internal.RequestState to for updating the state,
and use it for long-running requests.
Display the state on the worker main page.
Change-Id: I1a04036982aba23cf27776fac75248972a1336f3
Reviewed-on: https://go-review.googlesource.com/c/pkgsite/+/568515
Reviewed-by: Michael Matloob <matloob@golang.org>
LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com>
kokoro-CI: kokoro <noreply+kokoro@google.com>
Diffstat (limited to 'internal/postgres/versionstate.go')
| -rw-r--r-- | internal/postgres/versionstate.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/internal/postgres/versionstate.go b/internal/postgres/versionstate.go index 12f53894..0c8870d6 100644 --- a/internal/postgres/versionstate.go +++ b/internal/postgres/versionstate.go @@ -120,8 +120,9 @@ type ModuleVersionStateForUpdate struct { // UpdateModuleVersionState inserts or updates the module_version_state table with // the results of a fetch operation for a given module version. func (db *DB) UpdateModuleVersionState(ctx context.Context, mvs *ModuleVersionStateForUpdate) (err error) { - defer derrors.WrapStack(&err, "UpsertModuleVersionState(ctx, %s@%s)", mvs.ModulePath, mvs.Version) - ctx, span := trace.StartSpan(ctx, "UpsertModuleVersionState") + defer derrors.WrapStack(&err, "UpdateModuleVersionState(ctx, %s@%s)", mvs.ModulePath, mvs.Version) + defer internal.RequestState(ctx, "updating module_version_states table")() + ctx, span := trace.StartSpan(ctx, "UpdateModuleVersionState") defer span.End() var numPackages *int |