@@ -167,7 +167,7 @@ func (a *API) Start(ctx xcontext.Context, requestor EventRequestor, jobDescripto
167
167
ev := & Event {
168
168
// To allow jobs to finish we do not allow passing cancel and pause
169
169
// signals to the job's context (therefore: xcontext.WithResetSignalers).
170
- Context : xcontext .WithResetSignalers (ctx ).WithTag ("api_method" , "start" ),
170
+ Context : xcontext .WithResetSignalers (ctx ).WithField ("api_method" , "start" ),
171
171
Type : EventTypeStart ,
172
172
ServerID : resp .ServerID ,
173
173
Msg : EventStartMsg {
@@ -191,7 +191,7 @@ func (a *API) Start(ctx xcontext.Context, requestor EventRequestor, jobDescripto
191
191
func (a * API ) Stop (ctx xcontext.Context , requestor EventRequestor , jobID types.JobID ) (Response , error ) {
192
192
resp := a .newResponse (ResponseTypeStop )
193
193
ev := & Event {
194
- Context : ctx .WithTag ("api_method" , "stop" ),
194
+ Context : ctx .WithField ("api_method" , "stop" ),
195
195
Type : EventTypeStop ,
196
196
ServerID : resp .ServerID ,
197
197
Msg : EventStopMsg {
@@ -214,7 +214,7 @@ func (a *API) Stop(ctx xcontext.Context, requestor EventRequestor, jobID types.J
214
214
func (a * API ) Status (ctx xcontext.Context , requestor EventRequestor , jobID types.JobID ) (Response , error ) {
215
215
resp := a .newResponse (ResponseTypeStatus )
216
216
ev := & Event {
217
- Context : ctx .WithTag ("api_method" , "status" ),
217
+ Context : ctx .WithField ("api_method" , "status" ),
218
218
Type : EventTypeStatus ,
219
219
ServerID : resp .ServerID ,
220
220
Msg : EventStatusMsg {
@@ -239,7 +239,7 @@ func (a *API) Status(ctx xcontext.Context, requestor EventRequestor, jobID types
239
239
func (a * API ) Retry (ctx xcontext.Context , requestor EventRequestor , jobID types.JobID ) (Response , error ) {
240
240
resp := a .newResponse (ResponseTypeRetry )
241
241
ev := & Event {
242
- Context : ctx .WithTag ("api_method" , "retry" ),
242
+ Context : ctx .WithField ("api_method" , "retry" ),
243
243
Type : EventTypeRetry ,
244
244
ServerID : resp .ServerID ,
245
245
Msg : EventRetryMsg {
@@ -266,7 +266,7 @@ func (a *API) Retry(ctx xcontext.Context, requestor EventRequestor, jobID types.
266
266
func (a * API ) List (ctx xcontext.Context , requestor EventRequestor , query * storage.JobQuery ) (Response , error ) {
267
267
resp := a .newResponse (ResponseTypeList )
268
268
ev := & Event {
269
- Context : ctx .WithTag ("api_method" , "list" ),
269
+ Context : ctx .WithField ("api_method" , "list" ),
270
270
Type : EventTypeList ,
271
271
ServerID : resp .ServerID ,
272
272
Msg : EventListMsg {
0 commit comments