mirror of
https://git.vectorsigma.ru/public/tubearchivist.git
synced 2026-08-05 00:49:19 +00:00
comment scrape sleep
This commit is contained in:
@@ -6,9 +6,11 @@ Functionality:
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
from time import sleep
|
||||||
|
|
||||||
from appsettings.src.config import AppConfig
|
from appsettings.src.config import AppConfig
|
||||||
from common.src.es_connect import ElasticWrap
|
from common.src.es_connect import ElasticWrap
|
||||||
|
from common.src.helper import get_sleep
|
||||||
from common.src.ta_redis import RedisQueue
|
from common.src.ta_redis import RedisQueue
|
||||||
from download.src.yt_dlp_base import YtWrap
|
from download.src.yt_dlp_base import YtWrap
|
||||||
|
|
||||||
@@ -219,6 +221,8 @@ class CommentList:
|
|||||||
if comment.json_data:
|
if comment.json_data:
|
||||||
comment.upload_comments()
|
comment.upload_comments()
|
||||||
|
|
||||||
|
sleep(get_sleep(self.config))
|
||||||
|
|
||||||
def notify(self, idx, total_videos):
|
def notify(self, idx, total_videos):
|
||||||
"""send notification on task"""
|
"""send notification on task"""
|
||||||
message = [f"Add comments for new videos {idx}/{total_videos}"]
|
message = [f"Add comments for new videos {idx}/{total_videos}"]
|
||||||
|
|||||||
Reference in New Issue
Block a user