@@ -40,7 +40,7 @@ public function execute(QueueInterface $queue, Message $message)
4040
4141 // Skip this iteration if the nodedata can not be fetched (deleted node)
4242 if (!$ nodeData instanceof NodeData) {
43- $ this ->log (sprintf ('action=indexing step=failed node=%s message="Node data could not be loaded" ' , $ node ['identifier ' ]), \LOG_ERR );
43+ $ this ->log (sprintf ('action=indexing step=skipped node=%s message="Node data could not be loaded" ' , $ node ['identifier ' ]), \LOG_NOTICE );
4444 continue ;
4545 }
4646
@@ -54,20 +54,18 @@ public function execute(QueueInterface $queue, Message $message)
5454
5555 // Skip this iteration if the node can not be fetched from the current context
5656 if (!$ currentNode instanceof NodeInterface) {
57- $ this ->log (sprintf ('action=indexing step=failed node=%s message="Node could not be processed" ' , $ node ['identifier ' ]));
57+ $ this ->log (sprintf ('action=indexing step=failed node=%s message="Node could not be processed" ' , $ node ['identifier ' ]), \ LOG_WARNING );
5858 continue ;
5959 }
6060
6161 $ this ->nodeIndexer ->setIndexNamePostfix ($ this ->indexPostfix );
62- $ this ->log (sprintf ('action=indexing step=started node=%s ' , $ currentNode ->getIdentifier ()));
63-
6462 $ this ->nodeIndexer ->indexNode ($ currentNode , $ this ->targetWorkspaceName );
6563 }
6664
6765 $ this ->nodeIndexer ->flush ();
6866 $ duration = microtime (true ) - $ startTime ;
6967 $ rate = $ numberOfNodes / $ duration ;
70- $ this ->log (sprintf ('action=indexing step=finished number_of_nodes=%d duration=%f nodes_per_second=%f ' , $ numberOfNodes , $ duration , $ rate ));
68+ $ this ->log (sprintf ('action=indexing step=finished number_of_nodes=%d duration=%f nodes_per_second=%f ' , $ numberOfNodes , $ duration , $ rate ), \ LOG_INFO );
7169 });
7270
7371 return true ;
0 commit comments