-
Notifications
You must be signed in to change notification settings - Fork 42
Open
Description
I left a TODO here tagging @tcnghia because he worked this magic for Pub/Sub:
terraform-infra-common/pkg/workqueue/gcs/gcs.go
Lines 70 to 72 in c79371c
| writer.Metadata = map[string]string{ | |
| // TODO(nghia): Extract and persist things like trace headers here. | |
| } |
I'm guessing it's not a ton of work, but we need to extract the relevant headers and encode them above.
Then restore them here:
terraform-infra-common/pkg/workqueue/gcs/gcs.go
Lines 250 to 253 in c79371c
| // Context implements workqueue.OwnedInProgressKey. | |
| func (o *inProgressKey) Context() context.Context { | |
| return o.ownerCtx | |
| } |
I also need to fix the dispatcher to properly use this Context() method, which is an oversight on my part, which I'll correct now.
Metadata
Metadata
Assignees
Labels
No labels