mirror of
https://github.com/ClusterCockpit/cc-backend
synced 2024-11-10 08:57:25 +01:00
do not close channel on wait
This commit is contained in:
parent
7c6344675c
commit
c4bdff2210
@ -411,7 +411,6 @@ func (r *JobRepository) TriggerArchiving(job *schema.Job){
|
|||||||
// Wait for background thread to finish pending archiving operations
|
// Wait for background thread to finish pending archiving operations
|
||||||
func (r *JobRepository) WaitForArchiving(){
|
func (r *JobRepository) WaitForArchiving(){
|
||||||
// close channel and wait for worker to process remaining jobs
|
// close channel and wait for worker to process remaining jobs
|
||||||
close(r.archiveChannel)
|
|
||||||
r.archivePending.Wait()
|
r.archivePending.Wait()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user