1375
}
1376
1378
>
tag.WorkflowNamespaceID(request.GetNamespaceId()),
1379
>
tag.WorkflowTaskQueueName(request.GetTaskQueuePartition().GetTaskQueue()),
1380
>
tag.NewInt("worker-count", len(request.GetWorkers())),
1381
>
tag.NewInt("partition-count", len(request.GetPartitions())),
1382
>
)
1383
>
1384
>
// Cancel polls for each worker.
1385
>
var cancelledCount int32
1386
>
for _, worker := range request.GetWorkers() {
1387
>
if worker.GetWorkerInstanceKey() != "" {
1388
>
e.shutdownWorkers.Put(worker.GetWorkerInstanceKey(), struct{}{})
1389
>
}
1390
>
cancelledCount += e.workerInstancePollers.CancelAll(worker.GetWorkerInstanceKey())
1391
}
1392
1393
// Remove each worker from poller history for each partition.
1395
>
partition := tqid.PartitionFromPartitionProto(partitionProto, request.GetNamespaceId())
1396
>
for _, worker := range request.GetWorkers() {
1397
>
e.removePollerFromHistory(ctx, partition, worker.GetWorkerIdentity())
1398
>
}
1399
}
1400
1401
>
return &matchingservice.CancelOutstandingWorkerPollsPartitionResponse{
matching_engine.go
1402
>
CancelledCount: cancelledCount,
1403
>
}, nil
1404
}
1405