diff --git a/src/import_manager.cc b/src/import_manager.cc
index e1f03976..7a139c03 100644
--- a/src/import_manager.cc
+++ b/src/import_manager.cc
@@ -12,7 +12,3 @@ bool ImportManager::StartQueryDbImport(const std::string& path) {
 void ImportManager::DoneQueryDbImport(const std::string& path) {
   querydb_processing_.erase(path);
 }
-
-bool ImportManager::HasActiveQuerydbImports() {
-  return !querydb_processing_.empty();
-}
\ No newline at end of file
diff --git a/src/import_manager.h b/src/import_manager.h
index 5540b0b5..3ec607c7 100644
--- a/src/import_manager.h
+++ b/src/import_manager.h
@@ -21,9 +21,6 @@ struct ImportManager {
   // The file has been fully imported and can be imported again later on.
   void DoneQueryDbImport(const std::string& path);
 
-  // Returns true if there any any files currently being imported.
-  bool HasActiveQuerydbImports();
-
   std::unordered_set<std::string> querydb_processing_;
 
   // TODO: use std::shared_mutex so we can have multiple readers.
diff --git a/src/messages/cquery_wait.cc b/src/messages/cquery_wait.cc
index 1a50adee..65fd626c 100644
--- a/src/messages/cquery_wait.cc
+++ b/src/messages/cquery_wait.cc
@@ -23,7 +23,6 @@ struct CqueryWaitHandler : MessageHandler {
     while (true) {
       bool has_work = false;
       has_work |= import_pipeline_status->num_active_threads != 0;
-      has_work |= import_manager->HasActiveQuerydbImports();
       has_work |= QueueManager::instance()->HasWork();
       has_work |=
           QueryDb_ImportMain(config, db, import_manager, import_pipeline_status,