Skip to content

Commit

Permalink
Update archivalQueueTaskExecutor.go
Browse files Browse the repository at this point in the history
  • Loading branch information
yux0 committed Nov 7, 2022
1 parent f826cf1 commit b63b48a
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions service/history/archivalQueueTaskExecutor.go
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,10 @@ func newArchivalQueueTaskExecutor(archiver archival.Archiver, shardContext shard
}
}

func (e *archivalQueueTaskExecutor) Execute(ctx context.Context, executable queues.Executable) (tags []metrics.Tag,
isActive bool, err error) {
func (e *archivalQueueTaskExecutor) Execute(
ctx context.Context,
executable queues.Executable,
) (tags []metrics.Tag, isActive bool, err error) {
task := executable.GetTask()
taskType := queues.GetArchivalTaskTypeTagValue(task)
tags = []metrics.Tag{
Expand Down

0 comments on commit b63b48a

Please sign in to comment.