Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

optimize log #470

Merged
merged 2 commits into from
Jan 23, 2025
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
optimize log
JoinTyang committed Jan 23, 2025
commit 5e042fbca8f63742e7d2b1c83f91df1a5313be3f
1 change: 0 additions & 1 deletion requirements.txt
Original file line number Diff line number Diff line change
@@ -4,7 +4,6 @@ pyjwt==2.9.*
pymysql==1.1.*
gevent==24.2.*
Flask==3.0.*
apscheduler==3.10.*
pyexiftool==0.4.*
beautifulsoup4==4.12.3
markdown-it-py==3.0.0
12 changes: 0 additions & 12 deletions seasearch/index_task/filename_index_updater.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,6 @@
import logging
import time
from threading import Thread, Event
from multiprocessing import Process

from apscheduler.triggers.interval import IntervalTrigger
from apscheduler.schedulers.gevent import GeventScheduler
from apscheduler.schedulers.background import BackgroundScheduler
from seafevents.seasearch.index_store.index_manager import IndexManager
from seafevents.seasearch.index_store.repo_file_name_index import RepoFileNameIndex
from seafevents.seasearch.index_store.repo_status_index import RepoStatusIndex
@@ -17,10 +12,6 @@

logger = logging.getLogger(__name__)

# logger = logging

# logger.Formatter('[%(asctime)s] [%(levelname)s] %(message)s')


class RepoFilenameIndexUpdater(object):
def __init__(self, config):
@@ -143,10 +134,7 @@ def update_repo_file_name_indexes(repo_status_filename_index, repo_filename_inde

clear_deleted_repo(repo_status_filename_index, repo_filename_index, index_manager, all_repos)

# from concurrent.futures import ProcessPoolExecutor
from apscheduler.executors.pool import ProcessPoolExecutor

# class RepoFilenameIndexUpdaterTimer(Process):
class RepoFilenameIndexUpdaterTimer(Thread):
def __init__(self, repo_status_filename_index, repo_filename_index, index_manager, repo_data, interval):
super(RepoFilenameIndexUpdaterTimer, self).__init__()