diff --git a/zerver/worker/queue_processors.py b/zerver/worker/queue_processors.py index 38002d2bbc..929579b8c5 100644 --- a/zerver/worker/queue_processors.py +++ b/zerver/worker/queue_processors.py @@ -539,7 +539,9 @@ class TestWorker(QueueProcessingWorker): class FetchLinksEmbedData(QueueProcessingWorker): def consume(self, event: Mapping[str, Any]) -> None: for url in event['urls']: + start_time = time.time() url_preview.get_link_embed_data(url) + logging.info("Time spent on get_link_embed_data for %s: %s", url, time.time() - start_time) message = Message.objects.get(id=event['message_id']) # If the message changed, we will run this task after updating the message