File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -11,4 +11,4 @@ WORKDIR /scheduler/
1111
1212COPY . .
1313
14- CMD python scheduler.py
14+ ENTRYPOINT [ " python" , " scheduler.py" ]
Original file line number Diff line number Diff line change 11import os
22import gzip
33import boto3
4- import logging . config
4+ import logging
55from datetime import datetime
66
77from clickhouse_driver import Client as ClickhouseClient
88
99from slack import send_slack_message , sizeof_fmt
1010
1111
12- logging .config .fileConfig ('logging.ini' )
1312logger = logging .getLogger ('ddgscheduler' )
1413
1514
Original file line number Diff line number Diff line change 11[loggers]
2- keys =root,ddgscheduler
2+ keys =root
33
44[handlers]
55keys =consoleHandler
@@ -11,11 +11,6 @@ keys=consoleFormatter
1111level =INFO
1212handlers =consoleHandler
1313
14- [logger_ddgscheduler]
15- level =DEBUG
16- handlers =consoleHandler
17- qualname =ddgscheduler
18-
1914[handler_consoleHandler]
2015class =StreamHandler
2116formatter =consoleFormatter
Original file line number Diff line number Diff line change 11import logging .config
22
3+ logging .config .fileConfig ('logging.ini' )
4+
35from apscheduler .triggers .cron import CronTrigger
4- from apscheduler .schedulers .background import BackgroundScheduler
6+ from apscheduler .schedulers .background import BackgroundScheduler , BlockingScheduler
57
68from env import get_env
79from server import AuthServer
810from dump import dump_database
911from slack import send_slack_message
1012
11- logging .config .fileConfig ('logging.ini' )
1213logger = logging .getLogger ('ddgscheduler' )
1314
1415
2122 dump_database (environment )
2223 time .sleep (300 )
2324 else :
24- dumper_scheduler = BackgroundScheduler ()
25+ if environment .get ('START_MANUAL_MANAGEMENT_SERVER' ):
26+ dumper_scheduler = BackgroundScheduler ()
27+ else :
28+ dumper_scheduler = BlockingScheduler ()
29+
2530 dumper_scheduler .add_job (lambda : dump_database (environment ), CronTrigger .from_crontab (environment .get ('CRON' )))
2631 dumper_scheduler .start ()
2732
Original file line number Diff line number Diff line change 1- import logging . config
1+ import logging
22from slack_sdk .webhook import WebhookClient
33
4- logging .config .fileConfig ('logging.ini' )
54logger = logging .getLogger ('ddgscheduler' )
65
76
You can’t perform that action at this time.
0 commit comments