fix panic
This commit is contained in:
parent
e9db83f09b
commit
631844fb98
|
@ -93,6 +93,10 @@ func main() {
|
|||
|
||||
log.Infof("Elasticsearch enabled: %t", cfg.ElasticsearchEnable)
|
||||
|
||||
if cfg.ElasticsearchSyncEnable {
|
||||
elastic.InitializeWorkers()
|
||||
}
|
||||
|
||||
Workers.InitializeWorkers()
|
||||
|
||||
cache.InitRecacheSemaphore(cfg.CacheRecacheCrawlerLimit)
|
||||
|
|
|
@ -12,9 +12,6 @@ var Queue *DeleteJobQueue
|
|||
var syncLock sync.Mutex
|
||||
|
||||
func SyncThread() {
|
||||
Queue = NewJobQueue()
|
||||
InitializeWorkers()
|
||||
|
||||
createCrazyfsIndex()
|
||||
|
||||
// Test connection to Elastic.
|
||||
|
|
Loading…
Reference in New Issue