1830
ctx context.Context,
1831
request *adminservice.ForceUnloadTaskQueuePartitionRequest,
1832
>
) (_ *adminservice.ForceUnloadTaskQueuePartitionResponse, err error) {
admin_handler.go
1833
>
defer log.CapturePanic(adh.logger, &err)
1834
>
1835
>
// validate request
1836
>
if request == nil {
1837
return nil, errRequestNotSet
1838
}
1840
return nil, errNamespaceNotSet
1841
}
1842
1843
>
namespaceID, err := adh.namespaceRegistry.GetNamespaceID(namespace.Name(request.GetNamespace()))
admin_handler.go
1844
>
if err != nil {
1845
return nil, err
1846
}
1847
1848
>
resp, err := adh.matchingClient.ForceUnloadTaskQueuePartition(ctx, &matchingservice.ForceUnloadTaskQueuePartitionRequest{
admin_handler.go
1849
>
NamespaceId: namespaceID.String(),
1850
>
TaskQueuePartition: request.GetTaskQueuePartition(),
1851
>
})
1852
>
1853
>
if err != nil {
1854
return nil, err
1855
}
1856
1857
// The response returned is for multiple build Id's
1858
>
return &adminservice.ForceUnloadTaskQueuePartitionResponse{
admin_handler.go
1859
>
WasLoaded: resp.WasLoaded,
1860
>
}, nil
1861
}
1862