diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-01 20:13:01 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-01 20:13:01 +0100 |
| commit | d5f5f92c4bb0fad5ed51bbfe9d528b43e2f6d517 (patch) | |
| tree | ae3bcacab083cf203696ed4c218516ee20191050 /api.py | |
| parent | 97079cb228dbed31671e09bbe981b45043330a65 (diff) | |
| download | processor-d5f5f92c4bb0fad5ed51bbfe9d528b43e2f6d517.tar.gz processor-d5f5f92c4bb0fad5ed51bbfe9d528b43e2f6d517.zip | |
log to file
Diffstat (limited to 'api.py')
| -rw-r--r-- | api.py | 12 |
1 files changed, 10 insertions, 2 deletions
@@ -36,7 +36,7 @@ class Worker(object): async def connect(self, sourcea, desta): """Connect to database.""" - logging.info("connecting to database") + logging.warning("connecting to database") self._queue = joblib.joblib.JobQueue() await self._queue.connect(**sourcea) await self._queue.setup() @@ -182,7 +182,15 @@ async def startup(): await worker.setup() await worker.start(4) -logging.basicConfig(level=logging.DEBUG) +logging.basicConfig( + filename="logs/processor.log", + filemode="a", + level=logging.DEBUG +) +console = logging.StreamHandler() +console.setLevel(logging.WARNING) +logging.getLogger("").addHandler(console) + loop = asyncio.get_event_loop() loop.run_until_complete(startup()) loop.run_forever() |
