@@ -725,31 +725,31 @@ def bulk_update_search(cls, nodes, index=None):
725725 from api .share .utils import update_share
726726 for _node in nodes :
727727 update_share (_node )
728- from website import search
728+ from website . search import search , exceptions
729729 try :
730- serialize = functools .partial (search .search . update_node , index = index , bulk = True , async_update = False )
731- search .search . bulk_update_nodes (serialize , nodes , index = index )
732- except search . exceptions .SearchUnavailableError as e :
730+ serialize = functools .partial (search .update_node , index = index , bulk = True , async_update = False )
731+ search .bulk_update_nodes (serialize , nodes , index = index )
732+ except exceptions .SearchUnavailableError as e :
733733 logger .exception (e )
734734 log_exception (e )
735735
736736 def update_search (self ):
737737 from api .share .utils import update_share
738738 update_share (self )
739- from website import search
739+ from website . search import search , exceptions
740740 try :
741- search .search . update_node (self , bulk = False , async_update = True )
741+ search .update_node (self , bulk = False , async_update = True )
742742 if self .collection_submissions .exists () and self .is_public :
743- search .search . update_collected_metadata (self ._id )
744- except search . exceptions .SearchUnavailableError as e :
743+ search .update_collected_metadata (self ._id )
744+ except exceptions .SearchUnavailableError as e :
745745 logger .exception (e )
746746 log_exception (e )
747747
748748 def delete_search_entry (self ):
749- from website import search
749+ from website . search import search , exceptions
750750 try :
751- search .search . delete_node (self )
752- except search . exceptions .SearchUnavailableError as e :
751+ search .delete_node (self )
752+ except exceptions .SearchUnavailableError as e :
753753 logger .exception (e )
754754 log_exception (e )
755755
0 commit comments